Conveyor<F, O> class abstract

Implemented types

• MonadPlusOps<Conveyor<F, dynamic>, O>

Constructors

Conveyor()

Properties

hashCode → int

The hash code for this object.

no setter, inherited

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

Methods

andThen<B>(covariant Conveyor<F, B> next) → Conveyor<F, B>

override

ap<B>(covariant Conveyor<F, Function1<O, B>> ff) → Conveyor<F, B>

override

appendElement(O o) → Conveyor<F, O>

override

asFinalizer() → Conveyor<F, O>

bind<O2>(covariant Function1<O, Conveyor<F, O2>> f) → Conveyor<F, O2>

override

buffer(Monoid<O> monoid, int n) → Conveyor<F, O>

chunk(int n) → Conveyor<F, IVector<O>>

concatenate(Monoid<O> monoid) → Conveyor<F, O>

drain<O2>() → Conveyor<F, O2>

drop(int n) → Conveyor<F, O>

dropWhile(bool f(O o)) → Conveyor<F, O>

empty() → Conveyor<F, O>

filter(bool f(O o)) → Conveyor<F, O>

override

flatMap<O2>(covariant Function1<O, Conveyor<F, O2>> f) → Conveyor<F, O2>

override

fold<O2>(O2 z, Function2<O2, O, O2> f) → Conveyor<F, O2>

foldWhile<O2>(O2 z, Function2<O2, O, O2> f, Function1<O2, bool> p) → Conveyor<F, O2>

interleave(Conveyor<F, O> c2) → Conveyor<F, O>

interpret<A>(A ifProduce(O head, Conveyor<F, O> tail), covariant A ifConsume(F req, Function1<Either<Object, dynamic>, Conveyor<F, O>> recv), A ifHalt(Object err)) → A

intersperse(O sep) → Conveyor<F, O>

kill<O2>() → Conveyor<F, O2>

lastOr(O o) → Conveyor<F, O>

lazyPlus(Conveyor<F, O> p()) → Conveyor<F, O>

map<O2>(O2 f(O o)) → Conveyor<F, O2>

override

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

onComplete(Conveyor<F, O> p()) → Conveyor<F, O>

onHalt(Conveyor<F, O> f(Object err)) → Conveyor<F, O>

onHaltEnd(Conveyor<F, O> f()) → Conveyor<F, O>

onto<O2>(Conveyor<F, O2> f(Conveyor<F, O> c)) → Conveyor<F, O2>

pipe<O2>(Conveyor<From<O>, O2> c2) → Conveyor<F, O2>

plus(covariant Conveyor<F, O> p) → Conveyor<F, O>

override

prependElement(O o) → Conveyor<F, O>

override

pure<B>(B b) → Conveyor<F, B>

repeat() → Conveyor<F, O>

repeatNonEmpty() → Conveyor<F, O>

repeatUntilExhausted() → Conveyor<F, O>

replace<B>(B replacement) → Conveyor<F, B>

override

skipDuplicates([Eq<O>? eq]) → Conveyor<F, O>

strengthL<B>(B b) → Conveyor<F, Tuple2<B, O>>

override

strengthR<B>(B b) → Conveyor<F, Tuple2<O, B>>

override

take(int n) → Conveyor<F, O>

takeWhile(bool f(O o)) → Conveyor<F, O>

tee<O2, O3>(Conveyor<F, O2> c2, Conveyor<Both<O, O2>, O3> t) → Conveyor<F, O3>

through<O2>(Conveyor<F, ChannelF<F, O, O2>> channel) → Conveyor<F, O2>

to(Conveyor<F, SinkF<F, O>> sink) → Conveyor<F, Unit>

toString() → String

A string representation of this object.

inherited

tryOrDie<O2>(Conveyor<F, O2> p()) → Conveyor<F, O2>

where(bool f(O o)) → Conveyor<F, O>

override

window(int n) → Conveyor<F, IVector<O>>

windowAll(int n) → Conveyor<F, IVector<O>>

zip<O2>(Conveyor<F, O2> c2) → Conveyor<F, Tuple2<O, O2>>

zipWith<O2, O3>(Conveyor<F, O2> c2, Function2<O, O2, O3> f) → Conveyor<F, O3>

Operators

operator +(Conveyor<F, O> p) → Conveyor<F, O>

operator ==(Object other) → bool

The equality operator.

inherited

operator |(Conveyor<From<O>, dynamic> c2) → Conveyor<F, dynamic>

Static Properties

End → _End

final

Kill → _Kill

final

Static Methods

consume<F, A, O>(F req, Function1<Either<Object, A>, Conveyor<F, O>> recv) → Conveyor<F, O>

halt<F, O>([Object? err]) → Conveyor<F, O>

produce<F, O>(O head, [Conveyor<F, O>? tail]) → Conveyor<F, O>

runLogIO<O>(Conveyor<Free<IOOp, dynamic>, O> cio) → Free<IOOp, IList<O>>

runLogTask<O>(Conveyor<Task, O> cto) → Task<IList<O>>

Try<F, O>(Conveyor<F, O> p()) → Conveyor<F, O>