All files / output kernel_push_channels.clas.mjs

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
1x
1x
1x
1x
1x
1x
1x
1x
1x
1x
 
 
 
 
 
 
1x
 
 
 
1x
 
 
1x
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
1x
1x
1x
const {cx_root} = await import("./cx_root.clas.mjs");
// kernel_push_channels.clas.abap
class kernel_push_channels {
  static STATIC_SUPER = undefined;
  static INTERNAL_TYPE = 'CLAS';
  static INTERNAL_NAME = 'KERNEL_PUSH_CHANNELS';
  static IMPLEMENTED_INTERFACES = [];
  static ATTRIBUTES = {};
  static METHODS = {"WAIT": {"visibility": "U", "parameters": {"SECONDS": {"type": () => {return new abap.types.Integer({qualifiedName: "I"});}, "is_optional": " ", "parm_kind": "I", "type_name": "IntegerType"}, "COND": {"type": () => {return new abap.types.Character(4);}, "is_optional": " ", "parm_kind": "I", "type_name": "AnyType"}}}};
  constructor() {
    this.me = new abap.types.ABAPObject();
    this.me.set(this);
    this.INTERNAL_ID = abap.internalIdCounter++;
    this.FRIENDS_ACCESS_INSTANCE = {
    };
  }
  async constructor_(INPUT) {
    if (super.constructor_) { await super.constructor_(INPUT); }
    return this;
  }
  async wait(INPUT) {
    return kernel_push_channels.wait(INPUT);
  }
  static async wait(INPUT) {
    let seconds = INPUT?.seconds;
    if (seconds?.getQualifiedName === undefined || seconds.getQualifiedName() !== "I") { seconds = undefined; }
    if (seconds === undefined) { seconds = new abap.types.Integer({qualifiedName: "I"}).set(INPUT.seconds); }
    let cond = INPUT?.cond;
    let lv_seconds = new abap.types.Integer({qualifiedName: "I"});
    let lv_condition = new abap.types.Character(1, {"qualifiedName":"ABAP_BOOL","ddicName":"ABAP_BOOL"});
    lv_seconds.set(abap.operators.multiply(seconds,new abap.types.Integer().set(1000)));
    abap.statements.assert(abap.compare.gt(lv_seconds, abap.IntegerFactory.get(0)));
    const indexBackup1 = abap.builtin.sy.get().index.get();
    let unique1472 = 1;
    while (abap.compare.gt(lv_seconds, abap.IntegerFactory.get(0))) {
      abap.builtin.sy.get().index.set(unique1472++);
      await new Promise(resolve => setTimeout(resolve, 100));
      lv_condition = cond() ? "X" : " ";
      if (abap.compare.eq(lv_condition, abap.builtin.abap_true)) {
        abap.builtin.sy.get().subrc.set(abap.IntegerFactory.get(0));
        abap.builtin.sy.get().index.set(indexBackup1);
        return;
      }
      lv_seconds.set(abap.operators.minus(lv_seconds,abap.IntegerFactory.get(100)));
    }
    abap.builtin.sy.get().index.set(indexBackup1);
    abap.builtin.sy.get().subrc.set(abap.IntegerFactory.get(4));
  }
}
abap.Classes['KERNEL_PUSH_CHANNELS'] = kernel_push_channels;
export {kernel_push_channels};