@@ -0,0 +21,4 @@
+	w.ctx, cancel = context.WithCancel(ctx)
+	stream, err := rpcapi.PutObject(&c.c, &w.respV2, client.WithContext(w.ctx))
+	if err != nil {
+		cancel()

@@ -0,0 +57,4 @@
+	req       v2object.PutRequest
+	partInit  v2object.PutObjectPartInit
+	partChunk v2object.PutObjectPartChunk
+	ctx       context.Context

@@ -0,0 +37,4 @@
+type objectWriterTransformer struct {
+	ot        transformer.ObjectTarget
+	it        internalTarget
+	ctx       context.Context

@@ -0,0 +28,4 @@
+		Key:                    key,
+		NextTargetInit:         func() transformer.ObjectTarget { return &w.it },
+		MaxSize:                prm.maxSize,
+		WithoutHomomorphicHash: true,

@@ -23,0 +18,4 @@
+// we simply assume that 3MB is large enough to reduce the
+// number of messages, and not to exceed the limit
+// (4MB by default for gRPC servers).
+const MaxChunkLen = 3 << 20

@@ -77,0 +62,4 @@
+type ObjectWriter interface {
+	// WriteHeader writes header of the object. Result means success.
+	// Failure reason can be received via Close.
+	WriteHeader(object.Object) bool

@@ -237,1 +130,3 @@
-	return &x.res, nil
+// WithEpoch specifies epoch for object when cut it on client side.
+func (x *PrmObjectPutInit) WithEpoch(epoch uint64) {
+	x.epoch = epoch

@@ -23,0 +19,4 @@
+// we simply assume that 3MB is large enough to reduce the
+// number of messages, and not to exceed the limit
+// (4MB by default for gRPC servers).
+const MaxChunkLen = 3 << 20

@@ -0,0 +46,4 @@
+func (x *objectWriterTransformer) Close(ctx context.Context) (*ResObjectPut, error) {
+	if ai, err := x.ot.Close(ctx); err != nil {
+		return nil, err
+	} else {

@@ -89,0 +72,4 @@
+	WriteHeader(context.Context, object.Object) bool
+	// WritePayloadChunk writes chunk of the object payload. Result means success.
+	// Failure reason can be received via Close.
+	WritePayloadChunk(context.Context, []byte) bool