pub fn subscribe<'a>(&'a self, filter: JsonValue, result: &str) -> TonResult<Box<dyn Stream<Item=Value, Error=TonError> + 'a>> {
        let result: SubscribeHandle = Interop::json_request(self.context, "queries.subscribe", ParamsOfSubscribe {
            table: self.name.to_owned(),
            filter: filter.to_string(),
            result: result.to_owned()
        })?;
        Ok(Box::new(SubscribeStream { collection: self, handle: result.handle }))
    }
/// Subscribe for object updates. Returns `Stream` containing objects states
Subscribe for object updates. Returns `Stream` containing objects states
Subscribe for object updates . Returns ` Stream ` containing objects states
pub fn subscribe<'a>(&'a self, filter: JsonValue, result: &str) -> TonResult<Box<dyn Stream<Item=Value, Error=TonError> + 'a>> {
        let result: SubscribeHandle = Interop::json_request(self.context, "queries.subscribe", ParamsOfSubscribe {
            table: self.name.to_owned(),
            filter: filter.to_string(),
            result: result.to_owned()
        })?;
        Ok(Box::new(SubscribeStream { collection: self, handle: result.handle }))
    }
pub fn subscribe < ' a > ( & ' a self , filter : JsonValue , result : & str ) -> TonResult < Box < dyn Stream < Item = Value , Error = TonError > + ' a > > { let result : SubscribeHandle = Interop :: json_request ( self . context , " " , ParamsOfSubscribe { table : self . name . to_owned ( ) , filter : filter . to_string ( ) , result : result . to_owned ( ) } ) ? ; Ok ( Box :: new ( SubscribeStream { collection : self , handle : result . handle } ) ) }
Subscribe for object updates.
Subscribe for object updates .
&'a self
filter
JsonValue
result
&str