@Test
public void canWriteDataFrameAfterGoAwayReceived() throws Exception {

    Http2Stream stream = createStream(STREAM_ID, false);
    goAwayReceived(STREAM_ID);
    ByteBuf data = mock(ByteBuf.class);
    encoder.writeData(ctx, STREAM_ID, data, 0, false, newPromise());
    verify(remoteFlow).addFlowControlled(eq(stream), any(FlowControlled.class));
}