我已经实现了 Chronicle Queue,为此我想编写单元测试用例。如何在使用 lambda 时捕获 ArgumentCaptor 参数。我想在测试用例中获取 writeBuffer 来验证数据。
public class Persister {
public Persister(SingleChronicleQueue chronicle) {
this.chronicle = chronicle;
}
public void write(int outBufferOffset) throws IOException {
ExcerptAppender appender = chronicle.acquireAppender();
appender.writeBytes(b -> {
b.writeInt(outBufferOffset);
b.write(writeBuffer, 0 , outBufferOffset);
});}
}
测试用例:
@Mock
SingleChronicleQueue chronicle;
@Mock
ExcerptAppender appender;
@Captor
ArgumentCaptor<WriteBytesMarshallable> argumentCaptorLambda;
Persister persister = new Persister();
@Test
public void shouldPersistByteMessage() throws IOException {
persister.write(MESSAGEBYTES);
verify(appender).writeBytes(argumentCaptorLambda.capture());
WriteBytesMarshallable lastValue = argumentCaptorLambda.getValue();
//final byte[] persistedBytes = ?? how to get writeBuffer here ??
//assertThat(readPersistedMessage(persistedBytes), is(MESSAGE));
}
谢谢