teger> streamSource3 =
        DataStreamSource.fromCollection(context, Arrays.asList(1, 1));
    streamSource1
        .union(streamSource2, streamSource3)
        .sink((SinkFunction<Integer>) value -> {
          LOG.info("UnionStreamTest, sink: {}", value);
          try {
            if (!Files.exists(Paths.get(sinkFileName))) {
              Files.createFile(Paths.get(sinkFileName));
            }
            Files.write(Paths.get(sinkFileName), value.toString().getBytes(),
                StandardOpenOption.APPEND);
          } catch (IOException e) {
            throw new RuntimeException(e);
          }
        });
    context.execute("UnionStreamTest");
    int sleptTime = 0;
    TimeUnit.SECONDS.sleep(3);
    while (true) {
      if (Files.exists(Paths.get(sinkFileName))) {
        TimeUnit.SECONDS.sleep(3);
        String text = String.join(", ", Files.readAllLines(Paths.get(sinkFileName)));
        Assert.assertEquals(text, StringUtils.repeat("1", 6));
        LOG.info("Execution succeed");
        break;
      }
      sleptTime += 1;
      if (sleptTime >= 60) {
        throw new RuntimeException("Execution not finished");
      }
      LOG.info("Wait finish...");
      TimeUnit.SECONDS.sleep(1);
    }
    context.stop();
    LOG.info("HybridStreamTest succeed");
  }

}


issuerepo: golang/go


'use strict';
  Object.defineProperty(exports, "__esModule", {
    value: true
  });
  exports.default = void 0;
  
  var _NodeCollapseOutlined = _interopRequireDefault(require('./lib/icons/NodeCollapseOutlined'));
  
  function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { 'default': obj }; }
  
  var _default = _NodeCollapseOutlined;
  exports.default = _default;
  module.exports = _default;

#!/usr/bin/ruby
x,y=gets.split.map(&:to_i)
w=[0,3,16,34,55,80,108,139,172,208,245,285,327].take_while{|e|(y+3)/6>=e}.size-1
puts (w==0?'C':['N','NNE','NE','ENE','E','ESE','SE','SSE','S','SSW','SW','WSW','W','WNW','NW','NNW'][(x+112)%3600/225])+" #{w}"

//>>built
define(
//begin v1.x content
({
	w