docs: def unsubscribe_from_data(
          self,
          subscriber: Callable[[bytes], bool],
      ) -> None:
          """
          Not thread-safe.
  
          """
          self._data_subscribers.remove(subscriber)