Structure

URLSession.DataTaskPublisher

A publisher that delivers the results of performing URL session data tasks. あるパブリッシャー、それはURLセッションデータタスクを実行する結果を配達します。

Declaration 宣言 

struct DataTaskPublisher

Topics 話題

Declaring Publisher Topography パブリッシャーがよって立つ所を宣言する

typealias URLSession.DataTaskPublisher.Output
The kind of values published by this publisher. このパブリッシャーによって出版される値の種類。
typealias URLSession.DataTaskPublisher.Failure
The kind of errors this publisher might publish. このパブリッシャーが出版するかもしれないエラーの種類。

Creating a Data Task Publisher あるデータタスクパブリッシャーを作成する

init(request: URLRequest, session: URLSession)
Creates a data task publisher from the provided URL request and URL session. あるデータタスクパブリッシャーをこの提供されたURLリクエストとURLセッションから作成します。

Inspecting Data Task Properties データタスクプロパティを検査する

let request: URLRequest
The URL request performed by the data task associated with this publisher. このパブリッシャーと結びつけられたデータタスクによって実行されたURLリクエスト。
let session: URLSession
The URL session that performs the data task associated with this publisher. このパブリッシャーと結びつけられたデータタスクを実行するURLセッション。

Instance Properties インスタンスプロパティ

var values: AsyncThrowingPublisher<URLSession.DataTaskPublisher>

Instance Methods インスタンス メソッド

func allSatisfy(((data: Data, response: URLResponse)) -> Bool) -> Publishers.AllSatisfy<URLSession.DataTaskPublisher>
func append((data: Data, response: URLResponse)...) -> Publishers.Concatenate<URLSession.DataTaskPublisher, Publishers.Sequence<[(data: Data, response: URLResponse)], URLError>>
func assertNoFailure(String, file: StaticString, line: UInt) -> Publishers.AssertNoFailure<URLSession.DataTaskPublisher>
func breakpoint(receiveSubscription: ((Subscription) -> Bool)?, receiveOutput: (((data: Data, response: URLResponse)) -> Bool)?, receiveCompletion: ((Subscribers.Completion<URLError>) -> Bool)?) -> Publishers.Breakpoint<URLSession.DataTaskPublisher>
func breakpointOnError() -> Publishers.Breakpoint<URLSession.DataTaskPublisher>
func buffer(size: Int, prefetch: Publishers.PrefetchStrategy, whenFull: Publishers.BufferingStrategy<URLError>) -> Publishers.Buffer<URLSession.DataTaskPublisher>
func `catch`<P>((URLError) -> P) -> Publishers.Catch<URLSession.DataTaskPublisher, P>
func collect() -> Publishers.Collect<URLSession.DataTaskPublisher>
func collect(Int) -> Publishers.CollectByCount<URLSession.DataTaskPublisher>
func collect<S>(Publishers.TimeGroupingStrategy<S>, options: S.SchedulerOptions?) -> Publishers.CollectByTime<URLSession.DataTaskPublisher, S>
func combineLatest<P>(P) -> Publishers.CombineLatest<URLSession.DataTaskPublisher, P>
func combineLatest<P, Q>(P, Q) -> Publishers.CombineLatest3<URLSession.DataTaskPublisher, P, Q>
func combineLatest<P, T>(P, ((data: Data, response: URLResponse), P.Output) -> T) -> Publishers.Map<Publishers.CombineLatest<URLSession.DataTaskPublisher, P>, T>
func combineLatest<P, Q, R>(P, Q, R) -> Publishers.CombineLatest4<URLSession.DataTaskPublisher, P, Q, R>
func combineLatest<P, Q, T>(P, Q, ((data: Data, response: URLResponse), P.Output, Q.Output) -> T) -> Publishers.Map<Publishers.CombineLatest3<URLSession.DataTaskPublisher, P, Q>, T>
func combineLatest<P, Q, R, T>(P, Q, R, ((data: Data, response: URLResponse), P.Output, Q.Output, R.Output) -> T) -> Publishers.Map<Publishers.CombineLatest4<URLSession.DataTaskPublisher, P, Q, R>, T>
func compactMap<T>(((data: Data, response: URLResponse)) -> T?) -> Publishers.CompactMap<URLSession.DataTaskPublisher, T>
func contains(where: ((data: Data, response: URLResponse)) -> Bool) -> Publishers.ContainsWhere<URLSession.DataTaskPublisher>
func count() -> Publishers.Count<URLSession.DataTaskPublisher>
func debounce<S>(for: S.SchedulerTimeType.Stride, scheduler: S, options: S.SchedulerOptions?) -> Publishers.Debounce<URLSession.DataTaskPublisher, S>
func decode<Item, Coder>(type: Item.Type, decoder: Coder) -> Publishers.Decode<URLSession.DataTaskPublisher, Item, Coder>
func delay<S>(for: S.SchedulerTimeType.Stride, tolerance: S.SchedulerTimeType.Stride?, scheduler: S, options: S.SchedulerOptions?) -> Publishers.Delay<URLSession.DataTaskPublisher, S>
func drop<P>(untilOutputFrom: P) -> Publishers.DropUntilOutput<URLSession.DataTaskPublisher, P>
func drop(while: ((data: Data, response: URLResponse)) -> Bool) -> Publishers.DropWhile<URLSession.DataTaskPublisher>
func dropFirst(Int) -> Publishers.Drop<URLSession.DataTaskPublisher>
func eraseToAnyPublisher() -> AnyPublisher<(data: Data, response: URLResponse), URLError>
func filter(((data: Data, response: URLResponse)) -> Bool) -> Publishers.Filter<URLSession.DataTaskPublisher>
func first() -> Publishers.First<URLSession.DataTaskPublisher>
func first(where: ((data: Data, response: URLResponse)) -> Bool) -> Publishers.FirstWhere<URLSession.DataTaskPublisher>
func flatMap<T, P>(maxPublishers: Subscribers.Demand, ((data: Data, response: URLResponse)) -> P) -> Publishers.FlatMap<P, URLSession.DataTaskPublisher>
func flatMap<P>(maxPublishers: Subscribers.Demand, ((data: Data, response: URLResponse)) -> P) -> Publishers.FlatMap<Publishers.SetFailureType<P, URLError>, URLSession.DataTaskPublisher>
func handleEvents(receiveSubscription: ((Subscription) -> Void)?, receiveOutput: (((data: Data, response: URLResponse)) -> Void)?, receiveCompletion: ((Subscribers.Completion<URLError>) -> Void)?, receiveCancel: (() -> Void)?, receiveRequest: ((Subscribers.Demand) -> Void)?) -> Publishers.HandleEvents<URLSession.DataTaskPublisher>
func ignoreOutput() -> Publishers.IgnoreOutput<URLSession.DataTaskPublisher>
func last() -> Publishers.Last<URLSession.DataTaskPublisher>
func last(where: ((data: Data, response: URLResponse)) -> Bool) -> Publishers.LastWhere<URLSession.DataTaskPublisher>
func map<T>(((data: Data, response: URLResponse)) -> T) -> Publishers.Map<URLSession.DataTaskPublisher, T>
func map<T>(KeyPath<(data: Data, response: URLResponse), T>) -> Publishers.MapKeyPath<URLSession.DataTaskPublisher, T>
func map<T0, T1>(KeyPath<(data: Data, response: URLResponse), T0>, KeyPath<(data: Data, response: URLResponse), T1>) -> Publishers.MapKeyPath2<URLSession.DataTaskPublisher, T0, T1>
func map<T0, T1, T2>(KeyPath<(data: Data, response: URLResponse), T0>, KeyPath<(data: Data, response: URLResponse), T1>, KeyPath<(data: Data, response: URLResponse), T2>) -> Publishers.MapKeyPath3<URLSession.DataTaskPublisher, T0, T1, T2>
func mapError<E>((URLError) -> E) -> Publishers.MapError<URLSession.DataTaskPublisher, E>
func max(by: ((data: Data, response: URLResponse), (data: Data, response: URLResponse)) -> Bool) -> Publishers.Comparison<URLSession.DataTaskPublisher>
func measureInterval<S>(using: S, options: S.SchedulerOptions?) -> Publishers.MeasureInterval<URLSession.DataTaskPublisher, S>
func merge(with: URLSession.DataTaskPublisher) -> Publishers.MergeMany<URLSession.DataTaskPublisher>
func merge<B, C>(with: B, C) -> Publishers.Merge3<URLSession.DataTaskPublisher, B, C>
func merge<B, C, D>(with: B, C, D) -> Publishers.Merge4<URLSession.DataTaskPublisher, B, C, D>
func merge<B, C, D, E>(with: B, C, D, E) -> Publishers.Merge5<URLSession.DataTaskPublisher, B, C, D, E>
func merge<B, C, D, E, F>(with: B, C, D, E, F) -> Publishers.Merge6<URLSession.DataTaskPublisher, B, C, D, E, F>
func merge<B, C, D, E, F, G>(with: B, C, D, E, F, G) -> Publishers.Merge7<URLSession.DataTaskPublisher, B, C, D, E, F, G>
func merge<B, C, D, E, F, G, H>(with: B, C, D, E, F, G, H) -> Publishers.Merge8<URLSession.DataTaskPublisher, B, C, D, E, F, G, H>
func min(by: ((data: Data, response: URLResponse), (data: Data, response: URLResponse)) -> Bool) -> Publishers.Comparison<URLSession.DataTaskPublisher>
func multicast<S>(() -> S) -> Publishers.Multicast<URLSession.DataTaskPublisher, S>
func multicast<S>(subject: S) -> Publishers.Multicast<URLSession.DataTaskPublisher, S>
func output(at: Int) -> Publishers.Output<URLSession.DataTaskPublisher>
func output<R>(in: R) -> Publishers.Output<URLSession.DataTaskPublisher>
func prefix(Int) -> Publishers.Output<URLSession.DataTaskPublisher>
func prefix<P>(untilOutputFrom: P) -> Publishers.PrefixUntilOutput<URLSession.DataTaskPublisher, P>
func prefix(while: ((data: Data, response: URLResponse)) -> Bool) -> Publishers.PrefixWhile<URLSession.DataTaskPublisher>
func prepend((data: Data, response: URLResponse)...) -> Publishers.Concatenate<Publishers.Sequence<[(data: Data, response: URLResponse)], URLError>, URLSession.DataTaskPublisher>
func print(String, to: TextOutputStream?) -> Publishers.Print<URLSession.DataTaskPublisher>
func receive<S>(on: S, options: S.SchedulerOptions?) -> Publishers.ReceiveOn<URLSession.DataTaskPublisher, S>
func receive<S>(subscriber: S)
func reduce<T>(T, (T, (data: Data, response: URLResponse)) -> T) -> Publishers.Reduce<URLSession.DataTaskPublisher, T>
func removeDuplicates(by: ((data: Data, response: URLResponse), (data: Data, response: URLResponse)) -> Bool) -> Publishers.RemoveDuplicates<URLSession.DataTaskPublisher>
func replaceEmpty(with: (data: Data, response: URLResponse)) -> Publishers.ReplaceEmpty<URLSession.DataTaskPublisher>
func replaceError(with: (data: Data, response: URLResponse)) -> Publishers.ReplaceError<URLSession.DataTaskPublisher>
func replaceNil<T>(with: T) -> Publishers.Map<URLSession.DataTaskPublisher, T>
func retry(Int) -> Publishers.Retry<URLSession.DataTaskPublisher>
func scan<T>(T, (T, (data: Data, response: URLResponse)) -> T) -> Publishers.Scan<URLSession.DataTaskPublisher, T>
func share() -> Publishers.Share<URLSession.DataTaskPublisher>
func sink(receiveCompletion: ((Subscribers.Completion<URLError>) -> Void), receiveValue: (((data: Data, response: URLResponse)) -> Void)) -> AnyCancellable
func subscribe<S>(S) -> AnyCancellable
func subscribe<S>(S)
func subscribe<S>(on: S, options: S.SchedulerOptions?) -> Publishers.SubscribeOn<URLSession.DataTaskPublisher, S>
func throttle<S>(for: S.SchedulerTimeType.Stride, scheduler: S, latest: Bool) -> Publishers.Throttle<URLSession.DataTaskPublisher, S>
func timeout<S>(S.SchedulerTimeType.Stride, scheduler: S, options: S.SchedulerOptions?, customError: (() -> URLError)?) -> Publishers.Timeout<URLSession.DataTaskPublisher, S>
func tryAllSatisfy(((data: Data, response: URLResponse)) -> Bool) -> Publishers.TryAllSatisfy<URLSession.DataTaskPublisher>
func tryCatch<P>((URLError) -> P) -> Publishers.TryCatch<URLSession.DataTaskPublisher, P>
func tryCompactMap<T>(((data: Data, response: URLResponse)) -> T?) -> Publishers.TryCompactMap<URLSession.DataTaskPublisher, T>
func tryContains(where: ((data: Data, response: URLResponse)) -> Bool) -> Publishers.TryContainsWhere<URLSession.DataTaskPublisher>
func tryDrop(while: ((data: Data, response: URLResponse)) -> Bool) -> Publishers.TryDropWhile<URLSession.DataTaskPublisher>
func tryFilter(((data: Data, response: URLResponse)) -> Bool) -> Publishers.TryFilter<URLSession.DataTaskPublisher>
func tryFirst(where: ((data: Data, response: URLResponse)) -> Bool) -> Publishers.TryFirstWhere<URLSession.DataTaskPublisher>
func tryLast(where: ((data: Data, response: URLResponse)) -> Bool) -> Publishers.TryLastWhere<URLSession.DataTaskPublisher>
func tryMap<T>(((data: Data, response: URLResponse)) -> T) -> Publishers.TryMap<URLSession.DataTaskPublisher, T>
func tryMax(by: ((data: Data, response: URLResponse), (data: Data, response: URLResponse)) -> Bool) -> Publishers.TryComparison<URLSession.DataTaskPublisher>
func tryMin(by: ((data: Data, response: URLResponse), (data: Data, response: URLResponse)) -> Bool) -> Publishers.TryComparison<URLSession.DataTaskPublisher>
func tryPrefix(while: ((data: Data, response: URLResponse)) -> Bool) -> Publishers.TryPrefixWhile<URLSession.DataTaskPublisher>
func tryReduce<T>(T, (T, (data: Data, response: URLResponse)) -> T) -> Publishers.TryReduce<URLSession.DataTaskPublisher, T>
func tryRemoveDuplicates(by: ((data: Data, response: URLResponse), (data: Data, response: URLResponse)) -> Bool) -> Publishers.TryRemoveDuplicates<URLSession.DataTaskPublisher>
func tryScan<T>(T, (T, (data: Data, response: URLResponse)) -> T) -> Publishers.TryScan<URLSession.DataTaskPublisher, T>
func zip<P>(P) -> Publishers.Zip<URLSession.DataTaskPublisher, P>
func zip<P, Q>(P, Q) -> Publishers.Zip3<URLSession.DataTaskPublisher, P, Q>
func zip<P, T>(P, ((data: Data, response: URLResponse), P.Output) -> T) -> Publishers.Map<Publishers.Zip<URLSession.DataTaskPublisher, P>, T>
func zip<P, Q, R>(P, Q, R) -> Publishers.Zip4<URLSession.DataTaskPublisher, P, Q, R>
func zip<P, Q, T>(P, Q, ((data: Data, response: URLResponse), P.Output, Q.Output) -> T) -> Publishers.Map<Publishers.Zip3<URLSession.DataTaskPublisher, P, Q>, T>
func zip<P, Q, R, T>(P, Q, R, ((data: Data, response: URLResponse), P.Output, Q.Output, R.Output) -> T) -> Publishers.Map<Publishers.Zip4<URLSession.DataTaskPublisher, P, Q, R>, T>

Relationships 関係

Conforms To 次に準拠

See Also 参照

Performing Tasks as a Combine Publisher タスクをCombineパブリッシャーとして実行する

Processing URL Session Data Task Results with Combine URLセッションデータタスク結果をCombineで処理する
Use a chain of asynchronous operators to receive and process data fetched from a URL. あるURLから取って来たデータを受け取りそして処理するために、非同期演算子の連鎖を使ってください。
func dataTaskPublisher(for: URLRequest) -> URLSession.DataTaskPublisher
Returns a publisher that wraps a URL session data task for a given URL request. あるパブリッシャーを返します、それは与えられたURLリクエストに対するURLセッションデータタスクをラップするものです。
func dataTaskPublisher(for: URL) -> URLSession.DataTaskPublisher
Returns a publisher that wraps a URL session data task for a given URL. あるパブリッシャーを返します、それは与えられたURLに対するURLセッションデータタスクをラップするものです。