// Copyright 2015 The Vanadium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.

package io.v.impl.google.rpc;

import io.v.v23.rpc.Stream;
import io.v.v23.verror.VException;
import io.v.v23.vom.VomUtil;

import java.io.EOFException;
import java.lang.reflect.Type;

public class StreamImpl implements Stream {
    private final long nativePtr;

    private native void nativeSend(long nativePtr, byte[] vomItem) throws VException;
    private native byte[] nativeRecv(long nativePtr) throws EOFException, VException;
    private native void nativeFinalize(long nativePtr);

    private StreamImpl(long nativePtr) {
        this.nativePtr = nativePtr;
    }
    @Override
    public void send(Object item, Type type) throws VException {
        byte[] vomItem = VomUtil.encode(item, type);
        nativeSend(nativePtr, vomItem);
    }

    @Override
    public Object recv(Type type) throws EOFException, VException {
        byte[] result = nativeRecv(nativePtr);
        return VomUtil.decode(result, type);
    }
    @Override
    protected void finalize() {
        nativeFinalize(this.nativePtr);
    }
}