@@ -497,8 +497,8 @@ void main() {
497497 });
498498
499499 test ('can be listened to multiple times' , () async {
500- final subject =
501- HydratedSubject ( 'key' , seedValue: 1 , keyValueStore: mockKeyValueStore);
500+ final subject = HydratedSubject ( 'key' ,
501+ seedValue: 1 , keyValueStore: mockKeyValueStore);
502502 final stream = subject.stream;
503503
504504 await expectLater (stream, emits (1 ));
@@ -530,8 +530,8 @@ void main() {
530530 });
531531
532532 test ('setter `value=` has same behavior as adding to Subject' , () async {
533- final subject =
534- HydratedSubject < int ?>( 'key' , seedValue: 0 , keyValueStore: mockKeyValueStore);
533+ final subject = HydratedSubject < int ?>( 'key' ,
534+ seedValue: 0 , keyValueStore: mockKeyValueStore);
535535
536536 subject.value = 1 ;
537537
@@ -726,7 +726,8 @@ void main() {
726726 group ('override built-in' , () {
727727 test ('where' , () {
728728 {
729- var hydratedSubject = HydratedSubject ('key' , seedValue: 1 , keyValueStore: mockKeyValueStore);
729+ var hydratedSubject = HydratedSubject ('key' ,
730+ seedValue: 1 , keyValueStore: mockKeyValueStore);
730731
731732 var stream = hydratedSubject.where ((event) => event.isOdd);
732733 expect (stream, emitsInOrder (< int ? > [1 , 3 ]));
@@ -750,7 +751,8 @@ void main() {
750751
751752 test ('map' , () {
752753 {
753- var hydratedSubject = HydratedSubject ('key' , seedValue: 1 , keyValueStore: mockKeyValueStore);
754+ var hydratedSubject = HydratedSubject ('key' ,
755+ seedValue: 1 , keyValueStore: mockKeyValueStore);
754756
755757 var mapped = hydratedSubject.map ((event) => event + 1 );
756758 expect (mapped, emitsInOrder (< int ? > [2 , 3 ]));
@@ -772,7 +774,8 @@ void main() {
772774
773775 test ('asyncMap' , () {
774776 {
775- var hydratedSubject = HydratedSubject ('key' , seedValue: 1 , keyValueStore: mockKeyValueStore);
777+ var hydratedSubject = HydratedSubject ('key' ,
778+ seedValue: 1 , keyValueStore: mockKeyValueStore);
776779
777780 var mapped =
778781 hydratedSubject.asyncMap ((event) => Future .value (event + 1 ));
@@ -796,7 +799,8 @@ void main() {
796799
797800 test ('asyncExpand' , () {
798801 {
799- var hydratedSubject = HydratedSubject ('key' , seedValue: 1 , keyValueStore: mockKeyValueStore);
802+ var hydratedSubject = HydratedSubject ('key' ,
803+ seedValue: 1 , keyValueStore: mockKeyValueStore);
800804
801805 var stream =
802806 hydratedSubject.asyncExpand ((event) => Stream .value (event + 1 ));
@@ -820,7 +824,8 @@ void main() {
820824
821825 test ('handleError' , () {
822826 {
823- var hydratedSubject = HydratedSubject ('key' , seedValue: 1 , keyValueStore: mockKeyValueStore);
827+ var hydratedSubject = HydratedSubject ('key' ,
828+ seedValue: 1 , keyValueStore: mockKeyValueStore);
824829
825830 var stream = hydratedSubject.handleError (
826831 expectAsync1 <void , dynamic >(
@@ -862,7 +867,8 @@ void main() {
862867
863868 test ('expand' , () {
864869 {
865- var hydratedSubject = HydratedSubject ('key' , seedValue: 1 , keyValueStore: mockKeyValueStore);
870+ var hydratedSubject = HydratedSubject ('key' ,
871+ seedValue: 1 , keyValueStore: mockKeyValueStore);
866872
867873 var stream = hydratedSubject.expand ((event) => [event + 1 ]);
868874 expect (stream, emitsInOrder (< int ? > [2 , 3 ]));
@@ -884,7 +890,8 @@ void main() {
884890
885891 test ('transform' , () {
886892 {
887- var hydratedSubject = HydratedSubject ('key' , seedValue: 1 , keyValueStore: mockKeyValueStore);
893+ var hydratedSubject = HydratedSubject ('key' ,
894+ seedValue: 1 , keyValueStore: mockKeyValueStore);
888895
889896 var stream = hydratedSubject.transform (
890897 IntervalStreamTransformer (const Duration (milliseconds: 100 )));
@@ -931,7 +938,8 @@ void main() {
931938
932939 test ('take' , () {
933940 {
934- var hydratedSubject = HydratedSubject ('key' , seedValue: 1 , keyValueStore: mockKeyValueStore);
941+ var hydratedSubject = HydratedSubject ('key' ,
942+ seedValue: 1 , keyValueStore: mockKeyValueStore);
935943
936944 var stream = hydratedSubject.take (2 );
937945 expect (stream, emitsInOrder (< int ? > [1 , 2 ]));
@@ -955,7 +963,8 @@ void main() {
955963
956964 test ('takeWhile' , () {
957965 {
958- var hydratedSubject = HydratedSubject ('key' , seedValue: 1 , keyValueStore: mockKeyValueStore);
966+ var hydratedSubject = HydratedSubject ('key' ,
967+ seedValue: 1 , keyValueStore: mockKeyValueStore);
959968
960969 var stream = hydratedSubject.takeWhile ((element) => element <= 2 );
961970 expect (stream, emitsInOrder (< int ? > [1 , 2 ]));
@@ -979,7 +988,8 @@ void main() {
979988
980989 test ('skip' , () {
981990 {
982- var hydratedSubject = HydratedSubject ('key' , seedValue: 1 , keyValueStore: mockKeyValueStore);
991+ var hydratedSubject = HydratedSubject ('key' ,
992+ seedValue: 1 , keyValueStore: mockKeyValueStore);
983993
984994 var stream = hydratedSubject.skip (2 );
985995 expect (stream, emitsInOrder (< int ? > [3 , 4 ]));
@@ -1005,7 +1015,8 @@ void main() {
10051015
10061016 test ('skipWhile' , () {
10071017 {
1008- var hydratedSubject = HydratedSubject ('key' , seedValue: 1 , keyValueStore: mockKeyValueStore);
1018+ var hydratedSubject = HydratedSubject ('key' ,
1019+ seedValue: 1 , keyValueStore: mockKeyValueStore);
10091020
10101021 var stream = hydratedSubject.skipWhile ((element) => element < 3 );
10111022 expect (stream, emitsInOrder (< int ? > [3 , 4 ]));
@@ -1031,7 +1042,8 @@ void main() {
10311042
10321043 test ('distinct' , () {
10331044 {
1034- var hydratedSubject = HydratedSubject ('key' , seedValue: 1 , keyValueStore: mockKeyValueStore);
1045+ var hydratedSubject = HydratedSubject ('key' ,
1046+ seedValue: 1 , keyValueStore: mockKeyValueStore);
10351047
10361048 var stream = hydratedSubject.distinct ();
10371049 expect (stream, emitsInOrder (< int ? > [1 , 2 ]));
@@ -1057,7 +1069,8 @@ void main() {
10571069
10581070 test ('timeout' , () {
10591071 {
1060- var hydratedSubject = HydratedSubject ('key' , seedValue: 1 , keyValueStore: mockKeyValueStore);
1072+ var hydratedSubject = HydratedSubject ('key' ,
1073+ seedValue: 1 , keyValueStore: mockKeyValueStore);
10611074
10621075 var stream = hydratedSubject
10631076 .interval (const Duration (milliseconds: 100 ))
0 commit comments