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.