annotate src/main/java/org/msgpack/template/CollectionTemplate.java @ 0:cb825acd883a

first commit
author sugi
date Sat, 18 Oct 2014 15:06:15 +0900
parents
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
0
cb825acd883a first commit
sugi
parents:
diff changeset
1 //
cb825acd883a first commit
sugi
parents:
diff changeset
2 // MessagePack for Java
cb825acd883a first commit
sugi
parents:
diff changeset
3 //
cb825acd883a first commit
sugi
parents:
diff changeset
4 // Copyright (C) 2009 - 2013 FURUHASHI Sadayuki
cb825acd883a first commit
sugi
parents:
diff changeset
5 //
cb825acd883a first commit
sugi
parents:
diff changeset
6 // Licensed under the Apache License, Version 2.0 (the "License");
cb825acd883a first commit
sugi
parents:
diff changeset
7 // you may not use this file except in compliance with the License.
cb825acd883a first commit
sugi
parents:
diff changeset
8 // You may obtain a copy of the License at
cb825acd883a first commit
sugi
parents:
diff changeset
9 //
cb825acd883a first commit
sugi
parents:
diff changeset
10 // http://www.apache.org/licenses/LICENSE-2.0
cb825acd883a first commit
sugi
parents:
diff changeset
11 //
cb825acd883a first commit
sugi
parents:
diff changeset
12 // Unless required by applicable law or agreed to in writing, software
cb825acd883a first commit
sugi
parents:
diff changeset
13 // distributed under the License is distributed on an "AS IS" BASIS,
cb825acd883a first commit
sugi
parents:
diff changeset
14 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
cb825acd883a first commit
sugi
parents:
diff changeset
15 // See the License for the specific language governing permissions and
cb825acd883a first commit
sugi
parents:
diff changeset
16 // limitations under the License.
cb825acd883a first commit
sugi
parents:
diff changeset
17 //
cb825acd883a first commit
sugi
parents:
diff changeset
18 package org.msgpack.template;
cb825acd883a first commit
sugi
parents:
diff changeset
19
cb825acd883a first commit
sugi
parents:
diff changeset
20 import java.io.IOException;
cb825acd883a first commit
sugi
parents:
diff changeset
21 import java.util.Collection;
cb825acd883a first commit
sugi
parents:
diff changeset
22 import java.util.LinkedList;
cb825acd883a first commit
sugi
parents:
diff changeset
23 import org.msgpack.packer.Packer;
cb825acd883a first commit
sugi
parents:
diff changeset
24 import org.msgpack.unpacker.Unpacker;
cb825acd883a first commit
sugi
parents:
diff changeset
25 import org.msgpack.MessageTypeException;
cb825acd883a first commit
sugi
parents:
diff changeset
26
cb825acd883a first commit
sugi
parents:
diff changeset
27 public class CollectionTemplate<E> extends AbstractTemplate<Collection<E>> {
cb825acd883a first commit
sugi
parents:
diff changeset
28 private Template<E> elementTemplate;
cb825acd883a first commit
sugi
parents:
diff changeset
29
cb825acd883a first commit
sugi
parents:
diff changeset
30 public CollectionTemplate(Template<E> elementTemplate) {
cb825acd883a first commit
sugi
parents:
diff changeset
31 this.elementTemplate = elementTemplate;
cb825acd883a first commit
sugi
parents:
diff changeset
32 }
cb825acd883a first commit
sugi
parents:
diff changeset
33
cb825acd883a first commit
sugi
parents:
diff changeset
34 public void write(Packer pk, Collection<E> target, boolean required)
cb825acd883a first commit
sugi
parents:
diff changeset
35 throws IOException {
cb825acd883a first commit
sugi
parents:
diff changeset
36 if (target == null) {
cb825acd883a first commit
sugi
parents:
diff changeset
37 if (required) {
cb825acd883a first commit
sugi
parents:
diff changeset
38 throw new MessageTypeException("Attempted to write null");
cb825acd883a first commit
sugi
parents:
diff changeset
39 }
cb825acd883a first commit
sugi
parents:
diff changeset
40 pk.writeNil();
cb825acd883a first commit
sugi
parents:
diff changeset
41 return;
cb825acd883a first commit
sugi
parents:
diff changeset
42 }
cb825acd883a first commit
sugi
parents:
diff changeset
43 Collection<E> col = target;
cb825acd883a first commit
sugi
parents:
diff changeset
44 pk.writeArrayBegin(col.size());
cb825acd883a first commit
sugi
parents:
diff changeset
45 for (E e : col) {
cb825acd883a first commit
sugi
parents:
diff changeset
46 elementTemplate.write(pk, e);
cb825acd883a first commit
sugi
parents:
diff changeset
47 }
cb825acd883a first commit
sugi
parents:
diff changeset
48 pk.writeArrayEnd();
cb825acd883a first commit
sugi
parents:
diff changeset
49 }
cb825acd883a first commit
sugi
parents:
diff changeset
50
cb825acd883a first commit
sugi
parents:
diff changeset
51 public Collection<E> read(Unpacker u, Collection<E> to, boolean required)
cb825acd883a first commit
sugi
parents:
diff changeset
52 throws IOException {
cb825acd883a first commit
sugi
parents:
diff changeset
53 if (!required && u.trySkipNil()) {
cb825acd883a first commit
sugi
parents:
diff changeset
54 return null;
cb825acd883a first commit
sugi
parents:
diff changeset
55 }
cb825acd883a first commit
sugi
parents:
diff changeset
56 int n = u.readArrayBegin();
cb825acd883a first commit
sugi
parents:
diff changeset
57 if (to == null) {
cb825acd883a first commit
sugi
parents:
diff changeset
58 to = new LinkedList<E>();
cb825acd883a first commit
sugi
parents:
diff changeset
59 } else {
cb825acd883a first commit
sugi
parents:
diff changeset
60 to.clear();
cb825acd883a first commit
sugi
parents:
diff changeset
61 }
cb825acd883a first commit
sugi
parents:
diff changeset
62 for (int i = 0; i < n; i++) {
cb825acd883a first commit
sugi
parents:
diff changeset
63 E e = elementTemplate.read(u, null);
cb825acd883a first commit
sugi
parents:
diff changeset
64 to.add(e);
cb825acd883a first commit
sugi
parents:
diff changeset
65 }
cb825acd883a first commit
sugi
parents:
diff changeset
66 u.readArrayEnd();
cb825acd883a first commit
sugi
parents:
diff changeset
67 return to;
cb825acd883a first commit
sugi
parents:
diff changeset
68 }
cb825acd883a first commit
sugi
parents:
diff changeset
69 }