FakeNatsFastProducer

def connect(
    self,
    connection: Any,
    serializer: Optional["SerializerProto"],
    codec: Optional["CodecProto"] = None,
) -> None:
    raise NotImplementedError

def disconnect(self) -> None:
    raise NotImplementedError

@override
async def publish(self, cmd: "NatsPublishCommand") -> None:
    raise NotImplementedError

@override
async def request(self, cmd: "NatsPublishCommand") -> "Msg":
    raise NotImplementedError

@override
async def publish_batch(self, cmd: "NatsPublishCommand") -> None:
    msg = "NATS doesn't support publishing in batches."
    raise FeatureNotSupportedException(msg)