Skip to content

Upgrading dartz 0.3 to 0.4

Breaking0.3.6 → 0.4.5Breaking1New16Changed7Other2

BreakingUpgrade verdict

1 breaking change.

  • Code that used Conveyor and its friends must now import them from dartz_streaming instead of the main library.
1 item needs code or config changes
Breaking1
Moves Conveyor and related classes to the dartz_streaming library.
Conveyor

Generated by DepDelta from published Dart source. Not mixed with prose notes.

  • removed: class Both<L, R>
  • removed: class Conveyor<F, O>: abstract extends FunctorOps<Conveyor , O> with ApplicativeOps<Conveyor , O>, ApplicativePlusOps<Conveyor , O>, MonadOps<Conveyor , O>, MonadPlusOps<Conveyor , O>
  • removed: class From<A>
  • removed: class Nowhere
  • removed: class Pipe
  • removed: class Source
  • removed: class Tee
  • removed: function attempt(Free<IOOp, dynamic > fa): Free<IOOp, Either<Object, dynamic >>
  • removed: function closeFile(FileRef file): Free<IOOp, Unit>
  • removed: function conveyorMP(): MonadPlus<Conveyor >
  • removed: function openFile(String path, bool openForRead): Free<IOOp, FileRef>
  • removed: function println(String s): Free<IOOp, Unit>
  • removed: function readBytes(FileRef file, int byteCount): Free<IOOp, IList<int>>
  • removed: function writeBytes(FileRef file, IList<int> bytes): Free<IOOp, Unit>
  • removed: method Conveyor.asFinalizer(): Conveyor<F, O>
  • removed: method Conveyor.bind(Conveyor<F, dynamic > f(O o)): Conveyor<F, dynamic >
  • removed: method Conveyor.concatenate(Monoid<O> monoid): Conveyor<F, O>
  • removed: method Conveyor.drain(): Conveyor<F, dynamic >
  • removed: method Conveyor.drop(int n): Conveyor<F, O>
  • removed: method Conveyor.dropWhile(bool f(O o)): Conveyor<F, O>
  • removed: method Conveyor.empty(): Conveyor<F, O>
  • removed: method Conveyor.filter(bool f(O o)): Conveyor<F, O>
  • removed: method Conveyor.flatMap(Conveyor<F, dynamic > f(O o)): Conveyor<F, dynamic >
  • removed: method Conveyor.fold( z, Function2 f): Conveyor<F, dynamic >
  • removed: method Conveyor.interleave(Conveyor<F, O> c2): Conveyor<F, O>
  • removed: method Conveyor.interpret( ifProduce(O head, Conveyor<F, O> tail), ifConsume(F req, Function1<Either<Object, dynamic>, Conveyor<F, O>> recv), ifHalt(Object err))
  • removed: method Conveyor.intersperse(O sep): Conveyor<F, O>
  • removed: method Conveyor.kill(): Conveyor<F, dynamic >
  • removed: method Conveyor.lastOr(O o): Conveyor<F, O>
  • removed: method Conveyor.lazyPlus(Conveyor<F, O> p()): Conveyor<F, O>
  • removed: method Conveyor.map( f(O o)): Conveyor<F, dynamic >
  • removed: method Conveyor.onComplete(Conveyor<F, O> p()): Conveyor<F, O>
  • removed: method Conveyor.onHalt(Conveyor<F, O> f(Object err)): Conveyor<F, O>
  • removed: method Conveyor.onHaltEnd(Conveyor<F, O> f()): Conveyor<F, O>
  • removed: method Conveyor.operator +(Conveyor<F, O> p): Conveyor<F, O>
  • removed: method Conveyor.operator |(Conveyor<From<O>, dynamic> c2): Conveyor<F, dynamic>
  • removed: method Conveyor.pipe(Conveyor<From<O>, dynamic > c2): Conveyor<F, dynamic >
  • removed: method Conveyor.plus(Conveyor<F, O> p): Conveyor<F, O>
  • removed: method Conveyor.pure( b): Conveyor<F, dynamic >
  • removed: method Conveyor.repeat(): Conveyor<F, O>
  • removed: method Conveyor.repeatNonEmpty(): Conveyor<F, O>
  • removed: method Conveyor.repeatUntilExhausted(): Conveyor<F, O>
  • removed: method Conveyor.runLog(MonadCatch<F> monadCatch): F
  • removed: method Conveyor.take(int n): Conveyor<F, O>
  • removed: method Conveyor.takeWhile(bool f(O o)): Conveyor<F, O>
  • removed: method Conveyor.tee(Conveyor<F, dynamic > c2, Conveyor t): Conveyor<F, dynamic >
  • removed: method Conveyor.through(Conveyor<F, ChannelF<F, O, dynamic >> channel): Conveyor<F, dynamic >
  • removed: method Conveyor.to(Conveyor<F, SinkF<F, O>> sink): Conveyor<F, Unit>
  • removed: method Conveyor.tryOrDie(Conveyor p()): Conveyor
  • removed: method Conveyor.zip(Conveyor<F, dynamic > c2): Conveyor<F, Tuple2 >
  • removed: method Conveyor.zipWith(Conveyor<F, dynamic > c2, Function2 f): Conveyor<F, dynamic >
  • removed: static field Conveyor.End: final
  • removed: static field Conveyor.Kill: final
  • removed: static method Conveyor.Try(Conveyor p()): Conveyor
  • removed: static method Conveyor.consume( req, Function1<Either<Object, dynamic >, Conveyor > recv): Conveyor
  • removed: static method Conveyor.halt(Object err): Conveyor
  • removed: static method Conveyor.produce( head, [Conveyor tail]): Conveyor
  • removed: static method Pipe.consume(Function1 recv, [Function0 fallback]): Conveyor<From , dynamic >
  • removed: static method Pipe.drop(int n): Conveyor<From , dynamic >
  • removed: static method Pipe.dropWhile(bool f( i)): Conveyor<From , dynamic >
  • removed: static method Pipe.filter(bool f( i)): Conveyor<From , dynamic >
  • removed: static method Pipe.halt(): Conveyor<From , dynamic >
  • removed: static method Pipe.identity(): Conveyor<From , dynamic >
  • removed: static method Pipe.intersperse( sep): Conveyor<From , dynamic >
  • removed: static method Pipe.lift(Function1 f): Conveyor<From , dynamic >
  • removed: static method Pipe.produce( h, [Conveyor t]): Conveyor<From , dynamic >
  • removed: static method Pipe.scan( z, Function2 f): Conveyor<From , dynamic >
  • removed: static method Pipe.take(int n): Conveyor<From , dynamic >
  • removed: static method Pipe.takeWhile(bool f( i)): Conveyor<From , dynamic >
  • removed: static method Pipe.window2(): Conveyor<From , Tuple2 >
  • removed: static method Pipe.window2All(): Conveyor<From , Tuple2 >
  • removed: static method Source.constant(Monad monad, o): Conveyor
  • removed: static method Source.eval( fa): Conveyor
  • removed: static method Source.eval_( fa): Conveyor
  • removed: static method Source.fromFoldable( fo, Foldable foldable): Conveyor<Nowhere, dynamic >
  • removed: static method Source.fromIList( v): Conveyor<Nowhere, dynamic >
  • removed: static method Source.fromIVector( v): Conveyor<Nowhere, dynamic >
  • removed: static method Source.fromStream(Stream s()): Conveyor<Task, dynamic >
  • removed: static method Source.intsFrom(Monad monad, int from): Conveyor
  • removed: static method Source.materialize(Conveyor<Nowhere, dynamic > s, ApplicativePlus ap): dynamic
  • removed: static method Source.resource( acquire, Conveyor<dynamic , dynamic > use( r), Conveyor<dynamic , dynamic > release( r)): Conveyor
  • removed: static method Source.toIList(Conveyor<Nowhere, dynamic > s): IList
  • removed: static method Source.toIVector(Conveyor<Nowhere, dynamic > s): IVector
  • removed: static method Tee.consumeL(Function1 recv, [Function0 fallback]): Conveyor<Both , dynamic >
  • removed: static method Tee.consumeR(Function1 recv, [Function0 fallback]): Conveyor<Both , dynamic >
  • removed: static method Tee.halt(): Conveyor<Both , dynamic >
  • removed: static method Tee.interleave(): Conveyor<Both , dynamic >
  • removed: static method Tee.produce( h, [Conveyor<Both , dynamic > t]): Conveyor<Both , dynamic >
  • removed: static method Tee.zip(): Conveyor<Both , Tuple2 >
  • removed: static method Tee.zipWith(Function2 f): Conveyor<Both , dynamic >
  • removed: typedef Conveyor<F, O> ChannelF<F, I, O>(I i)
  • removed: typedef Conveyor<F, Unit> SinkF<F, O>(O o)
  • removed: variable ConveyorMP: final MonadPlus<Conveyor>
  • removed: variable readln: final Free<IOOp, String>
  • added: class Delay<A> extends IOOp<A>
  • added: class Execute extends IOOp<ExecutionResult>
  • added: class ExecutionResult
  • added: class Free2<First, Second>
  • added: class Free3<First, Second, Third>
  • added: class FreeComposer<F, C>: abstract
  • added: class FreeOps<F, O>
  • added: class IOOps<F> extends FreeOps<F, IOOp>
  • added: class IdFreeComposer<F> extends FreeComposer<F, F>
  • added: class IntSumMonoid extends Monoid<int>
  • added: class LeftFreeComposer<LL, L, R> extends FreeComposer<Either<L, R>, LL>
  • added: class RightFreeComposer<RR, L, R> extends FreeComposer<Either<L, R>, RR>
  • added: ctor Delay(this.duration, this.a)
  • added: ctor Execute(this.command, this.arguments)
  • added: ctor ExecutionResult(this.exitCode, this.stdout, this.stderr)
  • added: ctor FreeOps(this.composer)
  • added: ctor IOOps(FreeComposer<F, IOOp> composer)
  • added: ctor LeftFreeComposer(this._subComposer)
  • added: ctor RightFreeComposer(this._subComposer)
  • added: field Delay.a: final Free<IOOp,A>
  • added: field Delay.duration: final Duration
  • added: field Execute.arguments: final IList<String>
  • added: field Execute.command: final String
  • added: field ExecutionResult.exitCode: final int
  • added: field ExecutionResult.stderr: final String
  • added: field ExecutionResult.stdout: final String
  • added: field Free2.firstComposer: final FreeComposer<Either<First, Second>, First>
  • added: field Free2.secondComposer: final FreeComposer<Either<First, Second>, Second>
  • added: field Free3.firstComposer: final FreeComposer<Either<Either<First, Second>, Third>, First>
  • added: field Free3.secondComposer: final FreeComposer<Either<Either<First, Second>, Third>, Second>
  • added: field Free3.thirdComposer: final FreeComposer<Either<Either<First, Second>, Third>, Third>
  • added: field FreeOps.composer: final FreeComposer<F, O>
  • added: function composeInterpreters(lInterpreter( l), rInterpreter( r)): Function1<Either , dynamic>
  • added: function dualEndoMi(): Monoid<Endo >
  • added: function eitherTr(): Traversable<Either >
  • added: function emptyMap(): IMap
  • added: function endoMi(): Monoid<Endo >
  • added: function ilistMi(): Monoid<IList >
  • added: function iomc(): MonadCatch
  • added: function optionTr(): Traversable<Option >
  • added: function singletonMap( k, v): IMap
  • added: method Free.replace( b): Free
  • added: method Free2.interpreter(Monad M, firstInterpreter(First first), secondInterpreter(Second second)): Function1
  • added: method Free2.liftFirst(Free<First, dynamic > first): Free<Either<First, Second>, dynamic >
  • added: method Free2.liftSecond(Free<Second, dynamic > second): Free<Either<First, Second>, dynamic >
  • added: method Free3.interpreter(Monad M, firstInterpreter(First op), secondInterpreter(Second op), thirdInterpreter(Third op)): Function1
  • added: method Free3.liftFirst(Free<First, dynamic > first): Free<Either<Either<First, Second>, Third>, dynamic >
  • added: method Free3.liftSecond(Free<Second, dynamic > second): Free<Either<Either<First, Second>, Third>, dynamic >
  • added: method Free3.liftThird(Free<Third, dynamic > third): Free<Either<Either<First, Second>, Third>, dynamic >
  • added: method FreeComposer.embed(C c): F
  • added: method FreeComposer.lift(C c): Free<F, dynamic >
  • added: method FreeOps.liftOp(O o): Free<F, dynamic >
  • added: method IHashMap.operator[](K k): Option<V>
  • added: method IList.zip(IList bs): IList<Tuple2<A, dynamic >>
  • added: method IMap.operator[](K k): Option<V>
  • added: method IOMonad.pure( a): Free
  • added: method IOOps.attempt(Free<IOOp, dynamic > fa): Free<F, Either<Object, dynamic >>
  • added: method IOOps.closeFile(FileRef file): Free<F, Unit>
  • added: method IOOps.delay(Duration duration, Free<IOOp, dynamic > a): Free<F, dynamic >
  • added: method IOOps.execute(String command, IList<String> arguments): Free<F, ExecutionResult>
  • added: method IOOps.fail(Object failure): Free<F, dynamic >
  • added: method IOOps.openFile(String path, bool openForRead): Free<F, FileRef>
  • added: method IOOps.println(String s): Free<F, Unit>
  • added: method IOOps.readBytes(FileRef file, int byteCount): Free<F, IList<int>>
  • added: method IOOps.readln(): Free<F, String>
  • added: method IOOps.writeBytes(FileRef file, IList<int> bytes): Free<F, Unit>
  • added: method IVector.operator [](int i): Option<A>
  • added: method IdFreeComposer.embed(F f): F
  • added: method IntSumMonoid.append(int n1, int n2): int
  • added: method IntSumMonoid.zero(): int
  • added: method LeftFreeComposer.embed(LL l): Either<L, R>
  • added: method Order.maxSi(): Semigroup<A>
  • added: method Order.minSi(): Semigroup<A>
  • added: method RightFreeComposer.embed(RR r): Either<L, R>
  • added: method TraversableMonadPlus.reverse(F fa): F
  • added: method TraversableMonadPlusOps.reverse(): F
  • added: variable IntSumMi: final Monoid<int>
  • added: variable io: final
  • added: class Both<L, R>
  • added: class Conveyor<F, O>: abstract extends FunctorOps<Conveyor , O> with ApplicativeOps<Conveyor , O>, ApplicativePlusOps<Conveyor , O>, MonadOps<Conveyor , O>, MonadPlusOps<Conveyor , O>
  • added: class From<A>
  • added: class IO
  • added: class Nowhere
  • added: class Pipe
  • added: class Source
  • added: class Tee
  • added: class Text
  • added: function conveyorMP(): MonadPlus<Conveyor >
  • added: method Conveyor.asFinalizer(): Conveyor<F, O>
  • added: method Conveyor.bind(Conveyor<F, dynamic > f(O o)): Conveyor<F, dynamic >
  • added: method Conveyor.buffer(Monoid<O> monoid, int n): Conveyor<F, O>
  • added: method Conveyor.chunk(int n): Conveyor<F, IVector<O>>
  • added: method Conveyor.concatenate(Monoid<O> monoid): Conveyor<F, O>
  • added: method Conveyor.drain(): Conveyor<F, dynamic >
  • added: method Conveyor.drop(int n): Conveyor<F, O>
  • added: method Conveyor.dropWhile(bool f(O o)): Conveyor<F, O>
  • added: method Conveyor.empty(): Conveyor<F, O>
  • added: method Conveyor.filter(bool f(O o)): Conveyor<F, O>
  • added: method Conveyor.flatMap(Conveyor<F, dynamic > f(O o)): Conveyor<F, dynamic >
  • added: method Conveyor.fold( z, Function2 f): Conveyor<F, dynamic >
  • added: method Conveyor.foldWhile( z, Function2 f, Function1 p): Conveyor<F, dynamic >
  • added: method Conveyor.interleave(Conveyor<F, O> c2): Conveyor<F, O>
  • added: method Conveyor.interpret( ifProduce(O head, Conveyor<F, O> tail), ifConsume(F req, Function1<Either<Object, dynamic>, Conveyor<F, O>> recv), ifHalt(Object err))
  • added: method Conveyor.intersperse(O sep): Conveyor<F, O>
  • added: method Conveyor.kill(): Conveyor<F, dynamic >
  • added: method Conveyor.lastOr(O o): Conveyor<F, O>
  • added: method Conveyor.lazyPlus(Conveyor<F, O> p()): Conveyor<F, O>
  • added: method Conveyor.map( f(O o)): Conveyor<F, dynamic >
  • added: method Conveyor.onComplete(Conveyor<F, O> p()): Conveyor<F, O>
  • added: method Conveyor.onHalt(Conveyor<F, O> f(Object err)): Conveyor<F, O>
  • added: method Conveyor.onHaltEnd(Conveyor<F, O> f()): Conveyor<F, O>
  • added: method Conveyor.onto(Conveyor<F, dynamic > f(Conveyor<F, O> c)): Conveyor<F, dynamic >
  • added: method Conveyor.operator +(Conveyor<F, O> p): Conveyor<F, O>
  • added: method Conveyor.operator |(Conveyor<From<O>, dynamic> c2): Conveyor<F, dynamic>
  • added: method Conveyor.pipe(Conveyor<From<O>, dynamic > c2): Conveyor<F, dynamic >
  • added: method Conveyor.plus(Conveyor<F, O> p): Conveyor<F, O>
  • added: method Conveyor.pure( b): Conveyor<F, dynamic >
  • added: method Conveyor.repeat(): Conveyor<F, O>
  • added: method Conveyor.repeatNonEmpty(): Conveyor<F, O>
  • added: method Conveyor.repeatUntilExhausted(): Conveyor<F, O>
  • added: method Conveyor.runLog(MonadCatch<F> monadCatch): F
  • added: method Conveyor.skipDuplicates([Eq eq]): Conveyor<F, O>
  • added: method Conveyor.take(int n): Conveyor<F, O>
  • added: method Conveyor.takeWhile(bool f(O o)): Conveyor<F, O>
  • added: method Conveyor.tee(Conveyor<F, dynamic > c2, Conveyor t): Conveyor<F, dynamic >
  • added: method Conveyor.through(Conveyor<F, ChannelF<F, O, dynamic >> channel): Conveyor<F, dynamic >
  • added: method Conveyor.to(Conveyor<F, SinkF<F, O>> sink): Conveyor<F, Unit>
  • added: method Conveyor.tryOrDie(Conveyor p()): Conveyor
  • added: method Conveyor.zip(Conveyor<F, dynamic > c2): Conveyor<F, Tuple2 >
  • added: method Conveyor.zipWith(Conveyor<F, dynamic > c2, Function2 f): Conveyor<F, dynamic >
  • added: static field Conveyor.End: final
  • added: static field Conveyor.Kill: final
  • added: static field IO.stdinReader: final Conveyor<Free<IOOp, dynamic>, String>
  • added: static field IO.stdoutWriter: final Conveyor<Free<IOOp, dynamic>, SinkF<Free<IOOp, dynamic>, String>>
  • added: static field Text.decodeUtf8: final Conveyor<From<IList<int>>, String>
  • added: static field Text.encodeUtf8: final Conveyor<From<String>, IList<int>>
  • added: static field Text.lines: final Conveyor<From<String>, String>
  • added: static method Conveyor.Try(Conveyor p()): Conveyor
  • added: static method Conveyor.consume( req, Function1<Either<Object, dynamic >, Conveyor > recv): Conveyor
  • added: static method Conveyor.halt([Object err]): Conveyor
  • added: static method Conveyor.produce( head, [Conveyor tail]): Conveyor
  • added: static method IO.fileLineReader(String path, [Conveyor<From<IList<int>>, String> _decoder, int chunkBytes = …]): Conveyor<Free<IOOp, dynamic>, String>
  • added: static method IO.fileReader(String path, [int chunkBytes = …]): Conveyor<Free<IOOp, dynamic>, IList<int>>
  • added: static method IO.fileStringWriter(String path, [Conveyor<From<String>, IList<int>> _encoder, int bufferCount = …]): Function1<Conveyor<Free<IOOp, dynamic>, String>, Conveyor<Free<IOOp, dynamic>, Unit>>
  • added: static method IO.fileWriter(String path): Conveyor<Free<IOOp, dynamic>, SinkF<Free<IOOp, dynamic>, IList<int>>>
  • added: static method Pipe.buffer(Monoid monoid, int n): Conveyor
  • added: static method Pipe.chunk(int n): Conveyor
  • added: static method Pipe.consume(Function1 recv, [Function0 fallback]): Conveyor
  • added: static method Pipe.drop(int n): Conveyor
  • added: static method Pipe.dropWhile(bool f( i)): Conveyor
  • added: static method Pipe.filter(bool f( i)): Conveyor
  • added: static method Pipe.halt(): Conveyor
  • added: static method Pipe.identity(): Conveyor
  • added: static method Pipe.intersperse( sep): Conveyor
  • added: static method Pipe.lift(Function1 f): Conveyor
  • added: static method Pipe.produce( h, [Conveyor t]): Conveyor
  • added: static method Pipe.scan( z, Function2 f): Conveyor
  • added: static method Pipe.scanWhile( z, Function2 f, Function1 p): Conveyor
  • added: static method Pipe.skipDuplicates([Eq _eq]): Conveyor
  • added: static method Pipe.take(int n): Conveyor
  • added: static method Pipe.takeWhile(bool f( i)): Conveyor
  • added: static method Pipe.uniteOption(): Conveyor
  • added: static method Pipe.window2(): Conveyor
  • added: static method Pipe.window2All(): Conveyor
  • added: static method Source.constant(Monad monad, o): Conveyor
  • added: static method Source.eval( fa): Conveyor
  • added: static method Source.eval_( fa): Conveyor
  • added: static method Source.fromFoldable( fo, Foldable foldable): Conveyor<Nowhere, dynamic >
  • added: static method Source.fromIList( v): Conveyor<Nowhere, dynamic >
  • added: static method Source.fromIVector( v): Conveyor<Nowhere, dynamic >
  • added: static method Source.fromStream(Stream s()): Conveyor<Task, dynamic >
  • added: static method Source.intsFrom(Monad monad, int from): Conveyor
  • added: static method Source.materialize(Conveyor<Nowhere, dynamic > s, ApplicativePlus ap): dynamic
  • added: static method Source.pure(Monad monad, o): Conveyor
  • added: static method Source.repeatEval( fa): Conveyor
  • added: static method Source.repeatEval_( fa): Conveyor
  • added: static method Source.resource( acquire, Conveyor<dynamic , dynamic > use( r), Conveyor<dynamic , dynamic > release( r)): Conveyor
  • added: static method Source.toIList(Conveyor<Nowhere, dynamic > s): IList
  • added: static method Source.toIVector(Conveyor<Nowhere, dynamic > s): IVector
  • added: static method Tee.consumeL(Function1 recv, [Function0 fallback]): Conveyor<Both , dynamic >
  • added: static method Tee.consumeR(Function1 recv, [Function0 fallback]): Conveyor<Both , dynamic >
  • added: static method Tee.halt(): Conveyor<Both , dynamic >
  • added: static method Tee.interleave(): Conveyor<Both , dynamic >
  • added: static method Tee.produce( h, [Conveyor<Both , dynamic > t]): Conveyor<Both , dynamic >
  • added: static method Tee.zip(): Conveyor<Both , Tuple2 >
  • added: static method Tee.zipWith(Function2 f): Conveyor<Both , dynamic >
  • added: typedef Conveyor<F, O> ChannelF<F, I, O>(I i)
  • added: typedef Conveyor<F, Unit> SinkF<F, O>(O o)
  • added: variable ConveyorMP: final MonadPlus<Conveyor>
  • added: function unsafeConveyIO(Conveyor<Free<IOOp, dynamic>, dynamic > conveyor): Future<Either<Object, IList >>
  • added: function unsafeIOInterpreter(IOOp io): Future