@Test
public void streamsAreNotSupported() {

  this.thrown.expect(IllegalArgumentException.class);
  Contract contract = new ReactiveDelegatingContract(new Contract.Default());
  contract.parseAndValidateMetadata(StreamsService.class);
}