Class: ObservableSubscription

ObservableSubscription()

Members

isDestroyed :boolean

Check if this observable subscription has been destroyed.
Type:
  • boolean
Source:

observable :Observable

Get the RxJS Observable for this subscription. Use this to pipe operators and subscribe to messages.
Type:
  • Observable
Source:

subscription :Subscription

Get the underlying ROS 2 subscription.
Type:
Source:

topic :string

Get the topic name.
Type:
  • string
Source:

Methods

complete()

Complete the observable and clean up resources. After calling this, no more messages will be emitted.
Source:

destroy()

Alias for complete() for consistency with RxJS naming.
Source:

ObservableSubscription(subscription)

new ObservableSubscription(subscription)

Create an ObservableSubscription wrapper.
Parameters:
Name Type Description
subscription Subscription The underlying ROS 2 subscription
Source:

Members

isDestroyed :boolean

Check if this observable subscription has been destroyed.
Type:
  • boolean
Source:

observable :Observable

Get the RxJS Observable for this subscription. Use this to pipe operators and subscribe to messages.
Type:
  • Observable
Source:

subscription :Subscription

Get the underlying ROS 2 subscription.
Type:
Source:

topic :string

Get the topic name.
Type:
  • string
Source:

Methods

complete()

Complete the observable and clean up resources. After calling this, no more messages will be emitted.
Source:

destroy()

Alias for complete() for consistency with RxJS naming.
Source: