项目原始demo,不改动
Você não pode selecionar mais de 25 tópicos Os tópicos devem começar com uma letra ou um número, podem incluir traços ('-') e podem ter até 35 caracteres.
Este repositório está arquivado. Você pode visualizar os arquivos e realizar clone, mas não poderá realizar push nem abrir issues e pull requests.
 
 
 
 

28 linhas
1.0 KiB

  1. "use strict";
  2. var async_1 = require('../scheduler/async');
  3. var isNumeric_1 = require('../util/isNumeric');
  4. var isScheduler_1 = require('../util/isScheduler');
  5. var windowTime_1 = require('../operators/windowTime');
  6. function windowTime(windowTimeSpan) {
  7. var scheduler = async_1.async;
  8. var windowCreationInterval = null;
  9. var maxWindowSize = Number.POSITIVE_INFINITY;
  10. if (isScheduler_1.isScheduler(arguments[3])) {
  11. scheduler = arguments[3];
  12. }
  13. if (isScheduler_1.isScheduler(arguments[2])) {
  14. scheduler = arguments[2];
  15. }
  16. else if (isNumeric_1.isNumeric(arguments[2])) {
  17. maxWindowSize = arguments[2];
  18. }
  19. if (isScheduler_1.isScheduler(arguments[1])) {
  20. scheduler = arguments[1];
  21. }
  22. else if (isNumeric_1.isNumeric(arguments[1])) {
  23. windowCreationInterval = arguments[1];
  24. }
  25. return windowTime_1.windowTime(windowTimeSpan, windowCreationInterval, maxWindowSize, scheduler)(this);
  26. }
  27. exports.windowTime = windowTime;
  28. //# sourceMappingURL=windowTime.js.map