RetryableGraphQLSubscriptionOperation

public final class RetryableGraphQLSubscriptionOperation<Payload>: @unchecked Sendable
    where Payload: Decodable, Payload: Sendable

Note

@unchecked Sendable because _task is mutable but every access is serialized by lock.


                    
                    
                    SubscriptionEvents

Swift

public typealias SubscriptionEvents = GraphQLSubscriptionEvent<Payload>


                    
                    
                    init(requestStream:)

Swift

public init(
    requestStream: AsyncStream<@Sendable () async throws -> AmplifyAsyncThrowingSequence<SubscriptionEvents>>
)


                    
                    
                    subscribe()

Swift

public func subscribe() -> AnyPublisher<SubscriptionEvents, APIError>