-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathindex.js
64 lines (64 loc) · 1.98 KB
/
index.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
const ProcQueue = ObjC.classes.ProcQueue;
const ProcQueueService = ProcQueue.sharedInstance();
const proc = {
send: (val) => {
send(val);
return proc.put('send', val);
},
put: (key, val) => {
const wrapper = { type: 'proc', payload: val };
return ProcQueueService
.procPutObject_forKey_(
JSON.stringify(wrapper), key)
.valueOf();
},
get: (key) => {
const wrapper = ProcQueueService
.procObjectForKey_(key)
.valueOf();
return wrapper.length ? JSON.parse(wrapper).payload : null;
},
take: (key) => {
const wrapper = ProcQueueService
.procPutObject_forKey_("", key)
.valueOf();
return wrapper.length ? JSON.parse(wrapper).payload : null;
},
queue_push: (key, val) => {
const wrapper = { type: 'proc', payload: val };
return ProcQueueService
.procQueuePushTailObject_forKey_(
JSON.stringify(wrapper), key)
.valueOf();
},
queue_pop: (key) => {
const wrapper = ProcQueueService
.procQueuePopTailObjectForKey_(key)
.valueOf();
return wrapper.length ? JSON.parse(wrapper).payload : null;
},
queue_unshift: (key, val) => {
const wrapper = { type: 'proc', payload: val };
return ProcQueueService
.procQueueUnshiftObject_forKey_(
JSON.stringify(wrapper), key)
.valueOf();
},
queue_shift: (key) => {
const wrapper = ProcQueueService
.procQueueShiftObjectForKey_(key)
.valueOf();
return wrapper.length ? JSON.parse(wrapper).payload : null;
},
queue_clear: (key) => {
return ProcQueueService
.procQueueClearObjectsForKey_(key)
.valueOf();
},
queue_size: (key) => {
return ProcQueueService
.procQueueSizeForKey_(key)
.valueOf();
}
};
export default proc;