package com.hdl.sdk.link.socket.codec;

import com.hdl.sdk.link.socket.bean.Packet;

import java.util.ArrayList;
import java.util.List;

/**
 * Created by Tong on 2021/9/23.
 */
public class MessagePipeLine implements IMessagePipeLine, IHandleMessage {

    public final List<IHandleFlow> queue = new ArrayList<>();

    @Override
    public void add(IHandleFlow flow) {
        queue.add(flow);
    }

    @Override
    public synchronized void clear() {
        queue.clear();
    }

    @Override
    public void read(Packet packet) throws Exception {
        for (int i = 0; i < queue.size(); i++) {
            IHandleFlow flow = queue.get(i);
            Object read = flow.read(packet);
//            try {
//                out = Objects.requireNonNull(read);
//            } catch (Exception ignored) {
//            }
        }
    }

//    @Override
//    public byte[] write(Packet packet) throws Exception {
//        for (int i = 0; i < queue.size(); i++) {
//            IHandleFlow flow = queue.get(i);
//            byte[] write = flow.write(packet);
//        }
//        return new byte[0];
//    }
}