Not thread-safe.

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

        """
        self._data_subscribers.append(subscriber)