BridgeGateway<SUBSCRIBER_OUTPUT extends Output, PUBLISHER_OUTPUT extends Output, SUBSCRIBER_INPUT extends Input> constructor

BridgeGateway<SUBSCRIBER_OUTPUT extends Output, PUBLISHER_OUTPUT extends Output, SUBSCRIBER_INPUT extends Input>({
  1. required UseCase<Entity> subscriberUseCase,
  2. required UseCase<Entity> publisherUseCase,
})

Implementation

BridgeGateway({
  required UseCase subscriberUseCase,
  required UseCase publisherUseCase,
})  : _subscriberUseCase = subscriberUseCase,
      _publisherUseCase = publisherUseCase {
  _subscriberUseCase.subscribe<SUBSCRIBER_OUTPUT, SUBSCRIBER_INPUT>(
    (output) {
      return Either<FailureInput, SUBSCRIBER_INPUT>.right(
        onResponse(
          _publisherUseCase.getOutput<PUBLISHER_OUTPUT>(),
        ),
      );
    },
  );
}