@Test(expected = RuntimeException.class) public void registerLinkHandler() { try { link.registerLinkHandler(incomingPreparePacket -> null); } catch (Exception e) { assertThat(e.getMessage()) .isEqualTo("StatelessSpspReceiver links never emit data, and thus should not have a registered DataHandler."); throw e; } }
@Override public void registerLinkHandler(final LinkHandler ilpDataHandler) throws LinkHandlerAlreadyRegisteredException { throw new RuntimeException( "StatelessSpspReceiver links never emit data, and thus should not have a registered DataHandler." ); }
StatelessSpspReceiverLink extends AbstractLink<StatelessSpspReceiverLinkSettings> implements Link<StatelessSpspReceiverLinkSettings> { @Override public void registerLinkHandler(final LinkHandler ilpDataHandler) throws LinkHandlerAlreadyRegisteredException { throw new RuntimeException( "StatelessSpspReceiver links never emit data, and thus should not have a registered DataHandler." ); } }
StatelessSpspReceiverLink extends AbstractLink<StatelessSpspReceiverLinkSettings> implements Link<StatelessSpspReceiverLinkSettings> { @Override public void registerLinkHandler(final LinkHandler ilpDataHandler) throws LinkHandlerAlreadyRegisteredException { throw new RuntimeException( "StatelessSpspReceiver links never emit data, and thus should not have a registered DataHandler." ); } StatelessSpspReceiverLink(
      final Supplier<InterledgerAddress> operatorAddressSupplier,
      final StatelessSpspReceiverLinkSettings linkSettings,
      final StreamReceiver streamReceiver
  ); }
StatelessSpspReceiverLink extends AbstractLink<StatelessSpspReceiverLinkSettings> implements Link<StatelessSpspReceiverLinkSettings> { @Override public void registerLinkHandler(final LinkHandler ilpDataHandler) throws LinkHandlerAlreadyRegisteredException { throw new RuntimeException( "StatelessSpspReceiver links never emit data, and thus should not have a registered DataHandler." ); } StatelessSpspReceiverLink(
      final Supplier<InterledgerAddress> operatorAddressSupplier,
      final StatelessSpspReceiverLinkSettings linkSettings,
      final StreamReceiver streamReceiver
  ); @Override void registerLinkHandler(final LinkHandler ilpDataHandler); @Override InterledgerResponsePacket sendPacket(final InterledgerPreparePacket preparePacket); @Override String toString(); }
StatelessSpspReceiverLink extends AbstractLink<StatelessSpspReceiverLinkSettings> implements Link<StatelessSpspReceiverLinkSettings> { @Override public void registerLinkHandler(final LinkHandler ilpDataHandler) throws LinkHandlerAlreadyRegisteredException { throw new RuntimeException( "StatelessSpspReceiver links never emit data, and thus should not have a registered DataHandler." ); } StatelessSpspReceiverLink(
      final Supplier<InterledgerAddress> operatorAddressSupplier,
      final StatelessSpspReceiverLinkSettings linkSettings,
      final StreamReceiver streamReceiver
  ); @Override void registerLinkHandler(final LinkHandler ilpDataHandler); @Override InterledgerResponsePacket sendPacket(final InterledgerPreparePacket preparePacket); @Override String toString(); static final String LINK_TYPE_STRING; static final LinkType LINK_TYPE; }