Storage Documentation

Extensions on LoopEndpoint

Methods

_resolve(with:​)

@_spi(Private)
    func _resolve<R: EndpointResolver>(with session: R) -> AsyncThrowingStream<Output, any Error>  

Fetch responses, from a given Input and URLSession.

Parameters

session R

The EndpointResolver used to fetch the response.

Returns

Some AsyncStream.

erase​ToAny​Loop​Endpoint()

func eraseToAnyLoopEndpoint() -> AnyLoopEndpoint<Output>  

Erase to AnyLoopEndpoint.

Returns

A valid AnyLoopEndpoint.

first()

func first() -> First<Self>  

Collect the first output and wrap it in a SingleEndpoint.

Returns

Some SingleEndpoint.

last()

func last() -> Last<Self>  

Collect the final output and wrap it in a SingleEndpoint.

Returns

Some SingleEndpoint.

collect()

func collect() -> Collect<Self>  

Collect all outputs and wrap them in a SingleEndpoint.

Returns

Some SingleEndpoint.

prefix(_:​)

func prefix(_ count: Int) -> Prefix<Self>  

Collect up to count outputs.

Parameters

count Int

A valid Int.

Returns

Some LoopEndpoint.