Trait fc_rpc::EthPubSubApiServer

pub trait EthPubSubApiServer: 'static + Send + Sync {
    type Metadata: PubSubMetadata;
    pub fn subscribe(
        &self, 
        Self::Metadata, 
        Subscriber<Result, Error>, 
        Kind, 
        Option<Params>
    );
    pub fn unsubscribe(
        &self, 
        Option<Self::Metadata>, 
        SubscriptionId
    ) -> Result<bool, Error>;

    pub fn to_delegate(self) -> IoDelegate<Self, Self::Metadata> { ... }
}

Eth PUB-SUB rpc interface.

Associated Types

type Metadata: PubSubMetadata

RPC Metadata

Loading content...

Required methods

pub fn subscribe(
    &self,
    Self::Metadata,
    Subscriber<Result, Error>,
    Kind,
    Option<Params>
)

Subscribe to Eth subscription.

pub fn unsubscribe(
    &self,
    Option<Self::Metadata>,
    SubscriptionId
) -> Result<bool, Error>

Unsubscribe from existing Eth subscription.

Loading content...

Provided methods

pub fn to_delegate(self) -> IoDelegate<Self, Self::Metadata>

Create an IoDelegate, wiring rpc calls to the trait methods.

Loading content...

Implementors

impl<B: BlockT, P, C, BE, H: ExHashT> EthPubSubApi for EthPubSubApi<B, P, C, BE, H> where
    B: BlockT<Hash = H256> + Send + Sync + 'static,
    P: TransactionPool<Block = B> + Send + Sync + 'static,
    C: ProvideRuntimeApi<B> + StorageProvider<B, BE> + BlockchainEvents<B> + AuxStore,
    C: HeaderBackend<B> + HeaderMetadata<B, Error = BlockChainError> + 'static,
    C: Send + Sync + 'static,
    C::Api: EthereumRuntimeRPCApi<B>,
    BE: Backend<B> + 'static,
    BE::State: StateBackend<BlakeTwo256>, 

type Metadata = Metadata

fn subscribe(
    &self,
    _metadata: Self::Metadata,
    subscriber: Subscriber<PubSubResult>,
    kind: Kind,
    params: Option<Params>
)

fn unsubscribe(
    &self,
    _metadata: Option<Self::Metadata>,
    subscription_id: SubscriptionId
) -> JsonRpcResult<bool>

Loading content...