Struct nostr_sdk::relay::Relay

source ·
pub struct Relay { /* private fields */ }
Expand description

Relay

Implementations§

source§

impl Relay

source

pub fn new( url: Url, pool_sender: Sender<RelayPoolMessage>, notification_sender: Sender<RelayPoolNotification>, proxy: Option<SocketAddr>, opts: RelayOptions ) -> Self

Create new Relay

source

pub fn url(&self) -> Url

Get relay url

source

pub fn proxy(&self) -> Option<SocketAddr>

Get proxy

source

pub async fn status(&self) -> RelayStatus

source

pub async fn document(&self) -> RelayInformationDocument

source

pub async fn subscription(&self) -> ActiveSubscription

source

pub async fn update_subscription_filters(&self, filters: Vec<Filter>)

source

pub fn opts(&self) -> RelayOptions

source

pub fn stats(&self) -> RelayConnectionStats

source

pub async fn connect(&self, wait_for_connection: bool)

Connect to relay and keep alive connection

source

pub async fn terminate(&self) -> Result<(), Error>

Disconnect from relay and set status to ‘Terminated’

source

pub async fn send_msg( &self, msg: ClientMessage, wait: bool ) -> Result<(), Error>

Send msg to relay

if wait arg is true, this method will wait for the msg to be sent

source

pub async fn subscribe( &self, filters: Vec<Filter>, wait: bool ) -> Result<SubscriptionId, Error>

Subscribe

source

pub async fn unsubscribe(&self, wait: bool) -> Result<(), Error>

Unsubscribe

source

pub async fn get_events_of_with_callback<F>( &self, filters: Vec<Filter>, timeout: Option<Duration>, callback: impl Fn(Event) -> F ) -> Result<(), Error>where F: Future<Output = ()>,

Get events of filters with custom callback

source

pub async fn get_events_of( &self, filters: Vec<Filter>, timeout: Option<Duration> ) -> Result<Vec<Event>, Error>

Get events of filters

source

pub fn req_events_of(&self, filters: Vec<Filter>, timeout: Option<Duration>)

Request events of filter. All events will be sent to notification listener, until the EOSE “end of stored events” message is received from the relay.

Trait Implementations§

source§

impl Clone for Relay

source§

fn clone(&self) -> Relay

Returns a copy of the value. Read more
1.0.0 · source§

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. Read more
source§

impl Debug for Relay

source§

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter. Read more
source§

impl PartialEq<Relay> for Relay

source§

fn eq(&self, other: &Self) -> bool

This method tests for self and other values to be equal, and is used by ==.
1.0.0 · source§

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

Auto Trait Implementations§

§

impl !RefUnwindSafe for Relay

§

impl Send for Relay

§

impl Sync for Relay

§

impl Unpin for Relay

§

impl !UnwindSafe for Relay

Blanket Implementations§

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T> Instrument for T

source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for Twhere U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> Same<T> for T

§

type Output = T

Should always be Self
source§

impl<T> ToOwned for Twhere T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<V, T> VZip<V> for Twhere V: MultiLane<T>,

§

fn vzip(self) -> V

source§

impl<T> WithSubscriber for T

source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more