Error:  Failures: 
Error:    ConnectedCommitterImplTest.receiveTimeout_closesConnection:250 
Wanted but not invoked:
mockRequestStream.closeSendWithError(
    <Api exception matcher>
);
-> at com.google.cloud.pubsublite.internal.wire.ConnectedCommitterImplTest.receiveTimeout_closesConnection(ConnectedCommitterImplTest.java:250)

However, there was exactly 1 interaction with this mock:
mockRequestStream.send(
    initial {
  subscription: "projects/12345/locations/us-east1-a/subscriptions/some_subscription"
  partition: 1024
}

);
-> at com.google.cloud.pubsublite.internal.wire.SingleConnection.initialize(SingleConnection.java:81)