@@ -88,14 +88,14 @@ public void testWriteWithLock() throws Exception {
8888 final TransferStatus status = new TransferStatus ().setLength (TransferStatus .UNKNOWN_LENGTH );
8989 final StoregateMultipartWriteFeature writer = new StoregateMultipartWriteFeature (session , nodeid );
9090 try {
91- final HttpResponseOutputStream <File > out = new StoregateWriteFeature ( session , nodeid ) .write (test , status , new DisabledConnectionCallback ());
91+ final HttpResponseOutputStream <File > out = writer .write (test , status , new DisabledConnectionCallback ());
9292 fail ();
9393 }
9494 catch (LockedException e ) {
9595 //
9696 }
9797 status .setLockId (lockId );
98- final HttpResponseOutputStream <File > out = new StoregateWriteFeature ( session , nodeid ) .write (test , status , new DisabledConnectionCallback ());
98+ final HttpResponseOutputStream <File > out = writer .write (test , status , new DisabledConnectionCallback ());
9999 assertNotNull (out );
100100 new StreamCopier (status , status ).transfer (new ByteArrayInputStream (content ), out );
101101 out .close ();
@@ -161,7 +161,7 @@ public void testWriteSingleByteUnknownLength() throws Exception {
161161 final TransferStatus status = new TransferStatus ().setLength (TransferStatus .UNKNOWN_LENGTH );
162162 final Path test = new Path (room , UUID .randomUUID ().toString (), EnumSet .of (Path .Type .file ));
163163 final StoregateMultipartWriteFeature writer = new StoregateMultipartWriteFeature (session , nodeid );
164- final HttpResponseOutputStream <File > out = new StoregateWriteFeature ( session , nodeid ) .write (test , status , new DisabledConnectionCallback ());
164+ final HttpResponseOutputStream <File > out = writer .write (test , status , new DisabledConnectionCallback ());
165165 assertNotNull (out );
166166 new StreamCopier (status , status ).transfer (new ByteArrayInputStream (content ), out );
167167 final String version = out .getStatus ().getId ();
0 commit comments