synchros2 package

Subpackages

• synchros2.launch package
  • Submodules
    • synchros2.launch.actions module
      • DeclareBooleanLaunchArgument
      • DeclareEnumLaunchArgument
      • convert_to_bool()
      • update_sigterm_sigkill_timeout()
    • synchros2.launch.arguments module
      • add_robot_name_argument()
      • add_verbose_argument()
    • synchros2.launch.substitutions module
      • not_any_substitution()
    • synchros2.launch.values module
      • LaunchConfigurationValues
  • Module contents

Submodules

• synchros2.action module
  • ActionAborted
  • ActionCancelled
  • ActionException
    • ActionException.__init__()
  • ActionFuture
    • ActionFuture.__init__()
    • ActionFuture.aborted
    • ActionFuture.accepted
    • ActionFuture.acknowledged
    • ActionFuture.acknowledgement
    • ActionFuture.add_done_callback()
    • ActionFuture.add_feedback_callback()
    • ActionFuture.as_future()
    • ActionFuture.cancel()
    • ActionFuture.cancelled
    • ActionFuture.feedback
    • ActionFuture.feedback_stream()
    • ActionFuture.finalization
    • ActionFuture.finalized
    • ActionFuture.goal_handle
    • ActionFuture.outcome
    • ActionFuture.result
    • ActionFuture.status
    • ActionFuture.succeeded
    • ActionFuture.tracks_feedback
  • ActionOutcome
    • ActionOutcome.__init__()
    • ActionOutcome.aborted
    • ActionOutcome.accepted
    • ActionOutcome.cancelled
    • ActionOutcome.feedback
    • ActionOutcome.result
    • ActionOutcome.status
    • ActionOutcome.succeeded
  • ActionRejected
  • ActionTimeout
  • Actionable
    • Actionable.__init__()
    • Actionable.action_client
    • Actionable.action_name
    • Actionable.action_type
    • Actionable.asynchronous()
    • Actionable.synchronous()
    • Actionable.wait_for_server()
  • ActionableProtocol
    • ActionableProtocol.__init__()
    • ActionableProtocol.action_client
    • ActionableProtocol.asynchronous()
    • ActionableProtocol.compose()
    • ActionableProtocol.synchronous()
    • ActionableProtocol.vectorized
    • ActionableProtocol.wait_for_server()
  • unwrap_outcome()
  • wait_and_return_outcome()
  • wait_for_outcome()
• synchros2.action_client module
  • ActionClientWrapper
    • ActionClientWrapper.__init__()
    • ActionClientWrapper.send_goal_and_wait()
    • ActionClientWrapper.send_goal_async_handle()
• synchros2.action_handle module
  • ActionHandle
    • ActionHandle.__init__()
    • ActionHandle.cancel()
    • ActionHandle.get_feedback_callback()
    • ActionHandle.result
    • ActionHandle.set_feedback_callback()
    • ActionHandle.set_on_cancel_failure_callback()
    • ActionHandle.set_on_cancel_success_callback()
    • ActionHandle.set_on_failure_callback()
    • ActionHandle.set_result_callback()
    • ActionHandle.set_send_goal_future()
    • ActionHandle.wait_for_acceptance()
    • ActionHandle.wait_for_result()
• synchros2.callables module
  • ComposableCallable
    • ComposableCallable.compose()
  • ComposedCallable
    • ComposedCallable.__init__()
    • ComposedCallable.asynchronous()
    • ComposedCallable.synchronous()
  • GeneralizedCallable
    • GeneralizedCallable.asynchronous()
    • GeneralizedCallable.asynchronously()
    • GeneralizedCallable.synchronous()
    • GeneralizedCallable.synchronously()
  • GeneralizedDecorator
    • GeneralizedDecorator.__init__()
  • GeneralizedFunction
    • GeneralizedFunction.__init__()
    • GeneralizedFunction.asynchronous()
    • GeneralizedFunction.synchronous()
  • GeneralizedGuard
    • GeneralizedGuard.__init__()
    • GeneralizedGuard.asynchronous()
    • GeneralizedGuard.synchronous()
  • GeneralizedMethod
    • GeneralizedMethod.Bound
      • GeneralizedMethod.Bound.__init__()
      • GeneralizedMethod.Bound.asynchronous()
      • GeneralizedMethod.Bound.synchronous()
    • GeneralizedMethod.Unbound
      • GeneralizedMethod.Unbound.__init__()
    • GeneralizedMethod.__init__()
    • GeneralizedMethod.async_overload()
    • GeneralizedMethod.asynchronous()
    • GeneralizedMethod.legacy()
    • GeneralizedMethod.rebind()
    • GeneralizedMethod.sync_overload()
    • GeneralizedMethod.synchronous()
    • GeneralizedMethod.transitional
  • GeneralizedMethodLike
  • VectorizedCallable
    • VectorizedCallable.asynchronous()
    • VectorizedCallable.synchronous()
  • VectorizingCallable
    • VectorizingCallable.vectorized
  • generalized_method()
  • starmap_async()
• synchros2.callback_groups module
  • NonReentrantCallbackGroup
    • NonReentrantCallbackGroup.__init__()
    • NonReentrantCallbackGroup.beginning_execution()
    • NonReentrantCallbackGroup.can_execute()
    • NonReentrantCallbackGroup.ending_execution()
• synchros2.clock module
  • wait_for()
• synchros2.context module
  • wait_for_shutdown()
• synchros2.executors module
  • AutoScalingMultiThreadedExecutor
    • AutoScalingMultiThreadedExecutor.Task
      • AutoScalingMultiThreadedExecutor.Task.__init__()
      • AutoScalingMultiThreadedExecutor.Task.cancel()
    • AutoScalingMultiThreadedExecutor.__init__()
    • AutoScalingMultiThreadedExecutor.add_static_thread_pool()
    • AutoScalingMultiThreadedExecutor.bind()
    • AutoScalingMultiThreadedExecutor.default_thread_pool
    • AutoScalingMultiThreadedExecutor.shutdown()
    • AutoScalingMultiThreadedExecutor.spin_once()
    • AutoScalingMultiThreadedExecutor.spin_once_until_future_complete()
    • AutoScalingMultiThreadedExecutor.thread_pools
  • AutoScalingThreadPool
    • AutoScalingThreadPool.Work
      • AutoScalingThreadPool.Work.__init__()
      • AutoScalingThreadPool.Work.args
      • AutoScalingThreadPool.Work.cancel()
      • AutoScalingThreadPool.Work.cancelled()
      • AutoScalingThreadPool.Work.execute()
      • AutoScalingThreadPool.Work.fn
      • AutoScalingThreadPool.Work.future
      • AutoScalingThreadPool.Work.kwargs
      • AutoScalingThreadPool.Work.notify_cancelation()
      • AutoScalingThreadPool.Work.pending()
    • AutoScalingThreadPool.Worker
      • AutoScalingThreadPool.Worker.__init__()
      • AutoScalingThreadPool.Worker.run()
    • AutoScalingThreadPool.__init__()
    • AutoScalingThreadPool.capped
    • AutoScalingThreadPool.scaling_event
    • AutoScalingThreadPool.shutdown()
    • AutoScalingThreadPool.submit()
    • AutoScalingThreadPool.wait()
    • AutoScalingThreadPool.workers
    • AutoScalingThreadPool.working
  • assign_coroutine()
  • background()
  • foreground()
• synchros2.feeds module
  • AdaptedMessageFeed
    • AdaptedMessageFeed.__init__()
    • AdaptedMessageFeed.feed
    • AdaptedMessageFeed.stop()
  • ExactSynchronizedMessageFeed
    • ExactSynchronizedMessageFeed.__init__()
  • FramedMessageFeed
    • FramedMessageFeed.__init__()
    • FramedMessageFeed.feed
    • FramedMessageFeed.stop()
  • MessageFeed
    • MessageFeed.__init__()
    • MessageFeed.close()
    • MessageFeed.flush()
    • MessageFeed.history
    • MessageFeed.latest
    • MessageFeed.latest_update
    • MessageFeed.link
    • MessageFeed.matching_update()
    • MessageFeed.recall()
    • MessageFeed.start()
    • MessageFeed.stop()
    • MessageFeed.stream()
    • MessageFeed.update
  • SynchronizedMessageFeed
    • SynchronizedMessageFeed.__init__()
  • SynchronizedMessageFeedBase
    • SynchronizedMessageFeedBase.__init__()
    • SynchronizedMessageFeedBase.feeds
    • SynchronizedMessageFeedBase.stop()
• synchros2.filters module
  • Adapter
    • Adapter.__init__()
    • Adapter.add()
  • ApproximateTimeSynchronizer
    • ApproximateTimeSynchronizer.__init__()
  • ExactTimeSynchronizer
    • ExactTimeSynchronizer.__init__()
  • Filter
    • Filter.__init__()
    • Filter.registerCallback()
    • Filter.signalMessage()
    • Filter.start()
    • Filter.stop()
    • Filter.unregisterCallback()
  • SimpleFilterProtocol
    • SimpleFilterProtocol.__init__()
    • SimpleFilterProtocol.registerCallback()
    • SimpleFilterProtocol.signalMessage()
  • Subscriber
    • Subscriber.__init__()
    • Subscriber.close()
  • TimeSynchronizerBase
    • TimeSynchronizerBase.__init__()
    • TimeSynchronizerBase.upstreams
  • TransformFilter
    • TransformFilter.__init__()
    • TransformFilter.add()
  • Tunnel
    • Tunnel.__init__()
    • Tunnel.close()
• synchros2.futures module
  • FutureConvertible
    • FutureConvertible.__init__()
    • FutureConvertible.as_future()
  • FutureLike
    • FutureLike.__init__()
    • FutureLike.add_done_callback()
    • FutureLike.cancel()
    • FutureLike.cancelled()
    • FutureLike.done()
    • FutureLike.exception()
    • FutureLike.result()
  • as_proper_future()
  • unwrap_future()
  • wait_and_return_result()
  • wait_for_future()
• synchros2.graph module
  • ensure_num_publishers()
  • ensure_num_publishers_async()
  • ensure_num_subscriptions()
  • ensure_num_subscriptions_async()
• synchros2.logging module
  • MemoizingRcutilsLogger
    • MemoizingRcutilsLogger.__init__()
    • MemoizingRcutilsLogger.debug()
    • MemoizingRcutilsLogger.error()
    • MemoizingRcutilsLogger.fatal()
    • MemoizingRcutilsLogger.get_child()
    • MemoizingRcutilsLogger.get_effective_level()
    • MemoizingRcutilsLogger.info()
    • MemoizingRcutilsLogger.is_enabled_for()
    • MemoizingRcutilsLogger.log()
    • MemoizingRcutilsLogger.name
    • MemoizingRcutilsLogger.set_level()
    • MemoizingRcutilsLogger.warn()
    • MemoizingRcutilsLogger.warning()
  • RcutilsLogHandler
    • RcutilsLogHandler.__init__()
    • RcutilsLogHandler.default_formatter
    • RcutilsLogHandler.emit()
    • RcutilsLogHandler.setLevel()
  • as_memoizing_logger()
  • logs_to_ros()
  • make_logging_function()
• synchros2.node module
  • Node
    • Node.__init__()
    • Node.default_callback_group
    • Node.destroy_node()
    • Node.destruction_requested
    • Node.waitables
  • suppressed()
• synchros2.process module
  • ROSAwareProcess
    • ROSAwareProcess.__init__()
    • ROSAwareProcess.cli
    • ROSAwareProcess.current
    • ROSAwareProcess.lock
    • ROSAwareProcess.try_shutdown()
    • ROSAwareProcess.wait_for_interrupt()
    • ROSAwareProcess.wait_for_shutdown()
  • current()
  • ensure_node()
  • executor()
  • load()
  • main()
  • managed()
  • node()
  • spin()
  • tf_listener()
  • try_shutdown()
  • unload()
  • wait_for_interrupt()
  • wait_for_shutdown()
• synchros2.publisher module
  • Publisher
    • Publisher.__init__()
    • Publisher.matched_subscriptions
    • Publisher.message_type
    • Publisher.publisher()
    • Publisher.subscription_matches()
• synchros2.scope module
  • ROSAwareScope
    • ROSAwareScope.LocalStack
      • ROSAwareScope.LocalStack.top
    • ROSAwareScope.__init__()
    • ROSAwareScope.context
    • ROSAwareScope.executor
    • ROSAwareScope.global_
    • ROSAwareScope.graph
    • ROSAwareScope.load()
    • ROSAwareScope.local
    • ROSAwareScope.managed()
    • ROSAwareScope.node
    • ROSAwareScope.spin()
    • ROSAwareScope.tf_listener
    • ROSAwareScope.unload()
  • clock()
  • current()
  • ensure_node()
  • executor()
  • load()
  • managed()
  • node()
  • spin()
  • tf_listener()
  • top()
  • unload()
• synchros2.service module
  • ServiceError
  • ServiceException
    • ServiceException.__init__()
  • ServiceTimeout
  • Serviced
    • Serviced.__init__()
    • Serviced.asynchronous()
    • Serviced.client
    • Serviced.service_name
    • Serviced.service_type
    • Serviced.synchronous()
    • Serviced.wait_for_service()
  • ServicedProtocol
    • ServicedProtocol.__init__()
    • ServicedProtocol.asynchronous()
    • ServicedProtocol.client
    • ServicedProtocol.synchronous()
    • ServicedProtocol.wait_for_service()
• synchros2.service_handle module
  • ServiceHandle
    • ServiceHandle.__init__()
    • ServiceHandle.result
    • ServiceHandle.set_on_failure_callback()
    • ServiceHandle.set_result_callback()
    • ServiceHandle.set_send_service_future()
    • ServiceHandle.wait()
• synchros2.single_goal_action_server module
  • SingleGoalActionServer
    • SingleGoalActionServer.__init__()
• synchros2.single_goal_multiple_action_servers module
  • SingleGoalMultipleActionServers
    • SingleGoalMultipleActionServers.__init__()
    • SingleGoalMultipleActionServers.cancel_callback()
    • SingleGoalMultipleActionServers.destroy()
    • SingleGoalMultipleActionServers.get_logger()
    • SingleGoalMultipleActionServers.goal_callback()
    • SingleGoalMultipleActionServers.handle_accepted_callback()
• synchros2.static_transform_broadcaster module
  • StaticTransformBroadcaster
    • StaticTransformBroadcaster.__init__()
    • StaticTransformBroadcaster.sendTransform()
• synchros2.subscription module
  • Subscription
    • Subscription.__init__()
    • Subscription.cancel()
    • Subscription.matched_publishers
    • Subscription.message_type
    • Subscription.publisher_matches()
    • Subscription.subscriber
    • Subscription.topic_name
    • Subscription.unsubscribe()
  • wait_for_message()
  • wait_for_message_async()
  • wait_for_messages()
  • wait_for_messages_async()
• synchros2.tf_listener_wrapper module
  • StampLike
    • StampLike.__init__()
    • StampLike.nanosec
    • StampLike.sec
  • TFListenerWrapper
    • TFListenerWrapper.__init__()
    • TFListenerWrapper.buffer
    • TFListenerWrapper.lookup_a_tform_b()
    • TFListenerWrapper.lookup_latest_timestamp()
    • TFListenerWrapper.shutdown()
    • TFListenerWrapper.wait_for_a_tform_b()
    • TFListenerWrapper.wait_for_a_tform_b_async()
  • TimeLike
    • TimeLike.__init__()
    • TimeLike.nanoseconds
  • from_time_like()
• synchros2.time module
  • as_proper_duration()
  • as_proper_time()
• synchros2.type_hints module
• synchros2.utilities module
  • Tape
    • Tape.Stream
      • Tape.Stream.__init__()
      • Tape.Stream.consumed
      • Tape.Stream.interrupt()
      • Tape.Stream.label
      • Tape.Stream.read()
      • Tape.Stream.try_read()
      • Tape.Stream.write()
    • Tape.__init__()
    • Tape.add_write_callback()
    • Tape.close()
    • Tape.content()
    • Tape.flush()
    • Tape.future_matching_write()
    • Tape.future_write
    • Tape.head
    • Tape.latest_write
    • Tape.write()
  • bind_to_thread()
  • cap()
  • either_or()
  • ensure()
  • fqn()
  • functional_decorator()
  • localized_error_message()
  • namespace_with()
  • skip()
  • synchronized()
  • take_kwargs()
  • throttle()

Module contents