[#31] Add CODEOWNERS

Signed-off-by: Vitaliy Potyarkin <v.potyarkin@yadro.com>

CODEOWNERS

@@ -0,0 +1,3 @@
+.*          @orikik
+.forgejo/.* @potyarkin
+Makefile    @potyarkin

client/src/main/java/info/frostfs/sdk/jdo/PutObjectParameters.java

@@ -6,7 +6,7 @@ import info.frostfs.sdk.dto.session.SessionToken;
 import lombok.Getter;
 import lombok.Setter;
 
-import java.io.FileInputStream;
+import java.io.InputStream;
 
 @Getter
 @Setter
@@ -16,7 +16,7 @@ public class PutObjectParameters {
     private ObjectHeader header;
 
     @NotNull
-    private FileInputStream payload;
+    private InputStream payload;
 
     private boolean clientCut;
     private int bufferMaxSize;
@@ -26,14 +26,14 @@ public class PutObjectParameters {
     private long currentStreamPosition;
     private long fullLength;
 
-    public PutObjectParameters(ObjectHeader header, FileInputStream payload, boolean clientCut, int bufferMaxSize) {
+    public PutObjectParameters(ObjectHeader header, InputStream payload, boolean clientCut, int bufferMaxSize) {
         this.header = header;
         this.payload = payload;
         this.clientCut = clientCut;
         this.bufferMaxSize = bufferMaxSize;
     }
 
-    public PutObjectParameters(ObjectHeader header, FileInputStream payload) {
+    public PutObjectParameters(ObjectHeader header, InputStream payload) {
         this.header = header;
         this.payload = payload;
     }

client/src/main/java/info/frostfs/sdk/services/impl/ObjectClientImpl.java

@@ -31,8 +31,8 @@ import info.frostfs.sdk.tools.Verifier;
 import info.frostfs.sdk.utils.Validator;
 import org.apache.commons.collections4.CollectionUtils;
 
-import java.io.FileInputStream;
 import java.io.IOException;
+import java.io.InputStream;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -329,17 +329,17 @@ public class ObjectClientImpl extends ContextAccessor implements ObjectClient {
         return new SearchReader(objectServiceBlockingClient.search(initRequest));
     }
 
-    private int readNBytes(FileInputStream fileInputStream, byte[] buffer, int size) {
+    private int readNBytes(InputStream inputStream, byte[] buffer, int size) {
         try {
-            return fileInputStream.readNBytes(buffer, 0, size);
+            return inputStream.readNBytes(buffer, 0, size);
         } catch (IOException exp) {
             throw new ProcessFrostFSException(exp.getMessage());
         }
     }
 
-    private long getStreamSize(FileInputStream fileInputStream) {
+    private long getStreamSize(InputStream inputStream) {
         try {
-            return fileInputStream.getChannel().size();
+            return inputStream.available();
         } catch (IOException exp) {
             throw new ProcessFrostFSException(exp.getMessage());
         }