DownstreamManager

open class DownstreamManager : NSObject

ダウンストリームを管理するクラス。

  • 開いているダウンストリームのストリームIDのリスト。

    Declaration

    Swift

    public var downstreamIds: [Int] { get }
  • tag

    オブジェクトを識別するためのタグ。

    Declaration

    Swift

    public var tag: Int

  • sync(removeClosedStream:completion:filters:) で使用するフィルターを生成するクラス。

    See more

    Declaration

    Swift

    public class RequestFilters

  • ダウンストリームを開いて、開いたストリームのストリームIDを返します。

    Declaration

    Swift

    public func open(srcEdgeId: String, dstEdgeId: String? = nil) throws -> Int

    Parameters

    srcEdgeId

    送信元エッジのUUID
    dstEdgeId

    送信先エッジのUUID

    Return Value

    開いたダウンストリームのストリームID

  • ダウンストリームを閉じます。また、設定済みのストリームIDを全てクリアします。

    Declaration

    Swift

    public func close(completion: @escaping (Error?) -> ())

    Parameters

    completion

    ストリーム終了時のコールバック

  • 指定したストリームIDのダウンストリームを閉じます。また、対象のストリームIDをクリアします。

    Declaration

    Swift

    public func close(streamIds: [Int], completion: @escaping (Error?) -> ())

    Parameters

    streamIds

    閉じるダウンストームのストリームIDを格納した配列
    completion

    ストリーム終了時のコールバック

  • クライアントが保持しているダウンストリームの状態をサーバーと同期します。

    Declaration

    Swift

    public func sync(removeClosedStream: Bool = true, completion: @escaping ([Error]?) -> (), filters: RequestFilters? = nil)

    Parameters

    removeClosedStream

    閉じられたストリームを削除するかどうか
    completion

    処理完了時のコールバック
    filters

    ダウンストリーム対象とするデータを表すフィルターのリスト

  • 閉じられているダウストリームを破棄します。

    Declaration

    Swift

    public func removeClosedDownstream()

  • Delegateを追加します。

    Declaration

    Swift

    public func addDelegate(delegate: IntdashClientDownstreamManagerDelegate)

    Parameters

    delegate

    追加するDelegate

  • Delegateを削除します。

    Declaration

    Swift

    public func removeDelegate(delegate: IntdashClientDownstreamManagerDelegate)

    Parameters

    delegate

    削除するDelegate

  • 割り当てを解除します。

    Declaration

    Swift

    public func dispose()