File tree Expand file tree Collapse file tree
main/java/com/jnape/palatable/lambda/functions
test/java/com/jnape/palatable/lambda/functions Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -97,7 +97,7 @@ static <A> Effect<A> fromConsumer(Consumer<A> consumer) {
9797 * @param sideEffect the {@link SideEffect}
9898 * @return the {@link Effect}
9999 */
100- static Effect <Unit > effect (SideEffect sideEffect ) {
100+ static < A > Effect <A > effect (SideEffect sideEffect ) {
101101 return effect (constantly (io (sideEffect )));
102102 }
103103
@@ -108,7 +108,7 @@ static Effect<Unit> effect(SideEffect sideEffect) {
108108 */
109109 @ SuppressWarnings ("unused" )
110110 static <A > Effect <A > noop () {
111- return effect (NOOP ). contraMap ( constantly ( UNIT )) ;
111+ return effect (NOOP );
112112 }
113113
114114 /**
Original file line number Diff line number Diff line change 99import java .util .concurrent .atomic .AtomicInteger ;
1010import java .util .function .Consumer ;
1111
12- import static com .jnape .palatable .lambda .adt .Unit .UNIT ;
1312import static com .jnape .palatable .lambda .functions .Effect .effect ;
1413import static com .jnape .palatable .lambda .functions .Effect .fromConsumer ;
1514import static com .jnape .palatable .lambda .functions .builtin .fn1 .Constantly .constantly ;
@@ -51,8 +50,8 @@ public void andThen() {
5150 public void staticFactoryMethods () {
5251 AtomicInteger counter = new AtomicInteger ();
5352
54- Effect <Unit > runnableEffect = effect (counter ::incrementAndGet );
55- runnableEffect .apply (UNIT ).unsafePerformIO ();
53+ Effect <String > sideEffect = effect (counter ::incrementAndGet );
54+ sideEffect .apply ("foo" ).unsafePerformIO ();
5655 assertEquals (1 , counter .get ());
5756
5857 Effect <AtomicInteger > fnEffect = Effect .fromConsumer (AtomicInteger ::incrementAndGet );
You can’t perform that action at this time.
0 commit comments