DataStreamPublisher Structure Reference


                    
                    
                    Output

Declaration

Swift

public typealias Output = DataStreamRequest.Stream<Value, AFError>


                    
                    
                    Failure

Declaration

Swift

public typealias Failure = Never


                    
                    
                    init(_:queue:serializer:)

Creates an instance which will serialize responses using the provided DataStreamSerializer.

Declaration

Swift

public init<Serializer: DataStreamSerializer>(_ request: DataStreamRequest, queue: DispatchQueue, serializer: Serializer)
    where Value == Serializer.SerializedObject

Parameters

`request`	`DataStreamRequest` for which to publish the response.
`queue`	`DispatchQueue` on which the `Stream<Value, AFError>` values will be published. `.main` by default.
`serializer`	`DataStreamSerializer` used to produce the published `Stream<Value, AFError>` values.


                    
                    
                    result()

Publishes only the Result of the DataStreamRequest.Stream‘s Events.

Declaration

Swift

public func result() -> AnyPublisher<Result<Value, AFError>, Never>

Return Value

The AnyPublisher publishing the Result<Value, AFError> value.


                    
                    
                    value()

Publishes the streamed values of the DataStreamRequest.Stream as a sequence of Value or fail with the AFError instance.

Declaration

Swift

public func value() -> AnyPublisher<Value, AFError>

Return Value

The AnyPublisher<Value, AFError> publishing the stream.


                    
                    
                    receive(subscriber:)

Declaration

Swift

public func receive<S>(subscriber: S) where S : Subscriber, S : Sendable, S.Failure == Never, S.Input == DataStreamRequest.Stream<Value, AFError>