Skip to content

Commit

Permalink
Merge pull request #56 from LoveCommunity/refactor/rename-data-to-state
Browse files Browse the repository at this point in the history
rename `data` to `state` when using `States`
  • Loading branch information
beeth0ven committed Jun 28, 2022
2 parents a4de72c + 5aaecc7 commit 0e25dc5
Show file tree
Hide file tree
Showing 17 changed files with 41 additions and 41 deletions.
4 changes: 2 additions & 2 deletions lib/src/observables/states/states_first.dart
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,9 @@ import 'states.dart';
@internal
T statesFirst<T>(States<T> states) {
Value<T>? result;
states.observe((data) {
states.observe((state) {
if (result == null) {
result = Value(data);
result = Value(state);
}
})
.dispose();
Expand Down
2 changes: 1 addition & 1 deletion test/observables/observables/observable_cast_test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@ void main() {

expect(
() {
cast.observe((data) {});
cast.observe((_) {});
},
throwsA(
isA<TypeError>()
Expand Down
6 changes: 3 additions & 3 deletions test/observables/observables/observable_combine_test.g.dart

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ void main() {
});
});

final observation = observable.observe((data) {});
final observation = observable.observe((_) {});

expect(invoked, 0);
observation.dispose();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,9 +17,9 @@ void main() {
final multicastReplay = observable.multicastReplay(3);

expect(invokes, 0);
final observation1 = multicastReplay.observe((data) {});
final observation1 = multicastReplay.observe((_) {});
expect(invokes, 1);
final observation2 = multicastReplay.observe((data) {});
final observation2 = multicastReplay.observe((_) {});
expect(invokes, 1);

observation1.dispose();
Expand All @@ -39,8 +39,8 @@ void main() {

final multicastReplay = observable.multicastReplay(3);

final observation1 = multicastReplay.observe((data) {});
final observation2 = multicastReplay.observe((data) {});
final observation1 = multicastReplay.observe((_) {});
final observation2 = multicastReplay.observe((_) {});

expect(invokes, 0);
observation1.dispose();
Expand Down Expand Up @@ -103,7 +103,7 @@ void main() {
multicastReplay,
);

final observation = multicastReplay.observe((data) {});
final observation = multicastReplay.observe((_) {});

expect(tester.recorded, []);
tester.startObserve();
Expand Down
22 changes: 11 additions & 11 deletions test/observables/observables/observable_multicast_test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -17,9 +17,9 @@ void main() {
final multicast = observable.multicast();

expect(invokes, 0);
final observation1 = multicast.observe((data) {});
final observation1 = multicast.observe((_) {});
expect(invokes, 1);
final observation2 = multicast.observe((data) {});
final observation2 = multicast.observe((_) {});
expect(invokes, 1);

observation1.dispose();
Expand All @@ -39,8 +39,8 @@ void main() {

final multicast = observable.multicast();

final observation1 = multicast.observe((data) {});
final observation2 = multicast.observe((data) {});
final observation1 = multicast.observe((_) {});
final observation2 = multicast.observe((_) {});

expect(invokes, 0);
observation1.dispose();
Expand Down Expand Up @@ -106,10 +106,10 @@ void main() {
);

expect(invokes, 0);
final observation1 = multicast.observe((data) {});
final observation1 = multicast.observe((_) {});
expect(invokes, 1);
expect(subject.observeInvokes, 1);
final observation2 = multicast.observe((data) {});
final observation2 = multicast.observe((_) {});
expect(invokes, 1);
expect(subject.observeInvokes, 2);

Expand Down Expand Up @@ -138,8 +138,8 @@ void main() {
},
);

final observation1 = multicast.observe((data) {});
final observation2 = multicast.observe((data) {});
final observation1 = multicast.observe((_) {});
final observation2 = multicast.observe((_) {});

expect(invokes, 0);
expect(subject.observationDisposeInvokes, 0);
Expand Down Expand Up @@ -168,8 +168,8 @@ void main() {
},
);

final observation1 = multicast.observe((data) {});
final observation2 = multicast.observe((data) {});
final observation1 = multicast.observe((_) {});
final observation2 = multicast.observe((_) {});

expect(subject.disposeInvokes, 0);
observation1.dispose();
Expand All @@ -196,7 +196,7 @@ void main() {
},
);

final observation = multicast.observe((data) {});
final observation = multicast.observe((_) {});

expect(subject.recorded, []);
await Future(() {});
Expand Down
2 changes: 1 addition & 1 deletion test/observables/observables/proxy_observable_test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,7 @@ void main() {
proxy: observable,
);

final observation = proxyObservable.observe((data) {});
final observation = proxyObservable.observe((_) {});

expect(invokes, 0);
observation.dispose();
Expand Down
10 changes: 5 additions & 5 deletions test/observables/states/states_cache_test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -19,9 +19,9 @@ void main() {
final cache = states.cache();

expect(invokes, 0);
final observation1 = cache.observe((data) {});
final observation1 = cache.observe((_) {});
expect(invokes, 1);
final observation2 = cache.observe((data) {});
final observation2 = cache.observe((_) {});
expect(invokes, 1);

observation1.dispose();
Expand All @@ -42,8 +42,8 @@ void main() {

final cache = states.cache();

final observation1 = cache.observe((data) {});
final observation2 = cache.observe((data) {});
final observation1 = cache.observe((_) {});
final observation2 = cache.observe((_) {});

expect(invokes, 0);
observation1.dispose();
Expand Down Expand Up @@ -111,7 +111,7 @@ void main() {
cache,
);

final observation = cache.observe((data) {});
final observation = cache.observe((_) {});

expect(tester.recorded, []);
tester.startObserve();
Expand Down
2 changes: 1 addition & 1 deletion test/observables/states/states_cast_test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,7 @@ void main() {

expect(
() {
cast.observe((data) {});
cast.observe((_) {});
},
throwsA(
isA<TypeError>()
Expand Down
6 changes: 3 additions & 3 deletions test/observables/states/states_combine_test.g.dart

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ void main() {
});
});

final observation = states.observe((data) {});
final observation = states.observe((_) {});

expect(invokes, 0);
observation.dispose();
Expand Down
4 changes: 2 additions & 2 deletions test/observables/states/states_from_test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ void main() {
final states = States.from(observable);

expect(invokes, 0);
final observation = states.observe((data) {});
final observation = states.observe((_) {});
expect(invokes, 1);

observation.dispose();
Expand All @@ -58,7 +58,7 @@ void main() {

final states = States.from(observable);

final observation = states.observe((data) {});
final observation = states.observe((_) {});

expect(invokes, 0);
observation.dispose();
Expand Down
2 changes: 1 addition & 1 deletion test/observables/states/states_map_test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,7 @@ void main() {
});

final map = states
.map<int>((data) => data.length);
.map<int>((state) => state.length);

final tester = StatesTester(
map,
Expand Down
2 changes: 1 addition & 1 deletion test/observables/subjects/publish_subject_test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -141,7 +141,7 @@ void main() {

expect(
() {
subject.observe((data) {});
subject.observe((_) {});
},
throwsA(
isA<StateError>()
Expand Down
2 changes: 1 addition & 1 deletion test/observables/subjects/replay_subject_test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -193,7 +193,7 @@ void main() {

expect(
() {
subject.observe((data) {});
subject.observe((_) {});
},
throwsA(
isA<StateError>()
Expand Down
2 changes: 1 addition & 1 deletion test/observables/subjects/value_subject_test.dart
Original file line number Diff line number Diff line change
Expand Up @@ -184,7 +184,7 @@ void main() {

expect(
() {
subject.observe((data) {});
subject.observe((_) {});
},
throwsA(
isA<StateError>()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,7 @@ String _observable(bool isLast, int n) {

String _startObserve() {
return '''
final observation = combine.observe((data) {});
final observation = combine.observe((_) {});
''';
}

Expand Down

0 comments on commit 0e25dc5

Please sign in to comment.