SinkProtocol

Swift

associatedtype Input

Swift

associatedtype Failure : Error

Swift

typealias Completion = Sink.Completion<Failure>

Swift

typealias Output = Result<Void, Completion>

Swift

mutating func pollSend(_ context: inout Context, _ item: Input) -> Poll<Output>

Swift

mutating func pollFlush(_ context: inout Context) -> Poll<Output>

Swift

mutating func pollClose(_ context: inout Context) -> Poll<Output>

Swift

public func makeSink() -> Self

Swift

@inlinable
public func makeBlockingSink() -> Sink._Private.Blocking<ThreadExecutor, Self>

Swift

@inlinable
public func makeBlockingSink<E>(on executor: E) -> Sink._Private.Blocking<E, Self> where E : BlockingExecutor

Swift

@inlinable
public func eraseToAnySink() -> AnySink<Input, Failure>

Swift

@inlinable
public func map<T>(_ adapt: @escaping (T) -> Input) -> Sink._Private.Map<T, Self>

Swift

@inlinable
public func mapError<E>(_ adapt: @escaping (Error) -> E) -> Sink._Private.MapError<E, Self>

Swift

@inlinable
public func flatMap<T, U>(_ adapt: @escaping (T) -> U) -> Sink._Private.FlatMap<T, U, Self>

Swift

@inlinable
public func buffer(_ count: Int) -> Sink._Private.Buffer<Self>

Swift

@inlinable
public func setFailureType<E>(to _: E.Type) -> Sink._Private.SetFailureType<E, Self> where E : Error, Self.Failure == Never

Swift

@inlinable
public func assertNoError(_ prefix: String = "", file: StaticString = #file, line: UInt = #line) -> Sink._Private.AssertNoError<Self>

Swift

@inlinable
public func sendAll<U>(_ stream: U, close: Bool = true) -> Sink._Private.SendAll<U, Self> where U : StreamConvertible, Self.Input == U.StreamType.Output

Swift

@inlinable
public func send(_ item: Input) -> Sink._Private.Send<Self>

Swift

@inlinable
public func flush() -> Sink._Private.Flush<Self>

Swift

@inlinable
public func close() -> Sink._Private.Close<Self>