dest.writeInt( data.size() );
for ( byte[] bytes : data )
{
dest.writeBytes( bytes );
}
<BUG>channel.close();
</BUG>
}
}
private static TransactionStream readTransactionStream( ChannelBuffer buffer )

dest.writeInt( data.size() );
for ( byte[] bytes : data )
{
dest.writeBytes( bytes );
}
channel.other().close();
}
}
private static TransactionStream readTransactionStream( ChannelBuffer buffer )
