package jp.ac.u_ryukyu.treevnc;

import com.glavsoft.rfb.encoding.decoder.ByteBuffer;

import java.util.concurrent.BlockingQueue;
import java.util.concurrent.TimeUnit;

/**
 * Created by OcBookPro on 15/01/15.
 */
public class SoundPacketQueue {

    private final BlockingQueue<byte[]> queue;

    public SoundPacketQueue(BlockingQueue<byte[]> queue) {
        this.queue = queue;
    }

    public void put(byte[] packet) {
        queue.offer(packet);
    }

    public byte[] get() throws InterruptedException {
        return queue.poll(1, TimeUnit.SECONDS);
    }
}