Pauses the stream.
503171
def pause(self):
        """"""
        res = librtmp.RTMP_Pause(self.client.rtmp, 1)

        if res < 1:
            raise RTMPError("Failed to pause")
522885
def pause(msg="Press Enter to Continue..."):
    """"""
    print('\n' + Fore.YELLOW + msg + Fore.RESET, end='')
    input()
499187
public synchronized final void pause() {
        if (isStop) return ;

        isPause = true;
        mPauseTimeInFuture = mStopTimeInFuture - SystemClock.elapsedRealtime();
        mHandler.removeMessages(MSG);
    }
645550
function pause(req, res) {
  res.send(null, Constants.OK);
  this.state.pause(req.args[0]);
}
426512
private void pause() {
        if (mHasAlreadyPlayed && !mIsPaused) {
            mIsPaused = true;
            if (!mIsPreparing) {
                mMediaPlayer.pause();
            }

            // broadcast event
            Intent intent = new Intent(PlaybackListener.ACTION_ON_PLAYER_PAUSED);
            mLocalBroadcastManager.sendBroadcast(intent);

            updateNotification();

            mMediaSession.setPlaybackState(MediaSessionWrapper.PLAYBACK_STATE_PAUSED);
            pauseTimer();
        }
    }
217895
def pause(self):
        
        # 1. stop the plumbing thread by raising a StopIteration on a stride 
        #    boundary
        if self._started.isSet() and \
           self._running.isSet() and \
           not self._pausing.isSet():
            self._pausing.set()
            self._plunger.join()
            del self._plunger
            self._pausing.clear()
            self._running.clear()
        else:
            raise PlumberError
1130841
def stop(cls):
        """"""
        if any(cls.streams):
            sys.stdout = cls.streams.pop(-1)
        else:
            sys.stdout = sys.__stdout__
328649
def pause(self):
        
        if not self._pause_level:
            self._paused_time = self._clock() + self._offset
            self._paused_frame = self.current_frame
        self._pause_level += 1
367071
private PauseResult<PersistableUpload> pause(
            final boolean forceCancelTransfers) throws AmazonClientException {
        UploadMonitor uploadMonitor = (UploadMonitor) monitor;
        return uploadMonitor.pause(forceCancelTransfers);
    }
255109
public void pause()
    {
        if (mAudioListener != null)
        {
            int sourceId = getSourceId();
            if (sourceId != GvrAudioEngine.INVALID_ID)
            {
                mAudioListener.getAudioEngine().pauseSound(sourceId);
            }
        }
    }
867512
def pause(self, pause=0):
        """"""
        fr = self.frames[-1]
        n = int(self.fps * pause)
        for i in range(n):
            fr2 = "/tmp/vpvid/" + str(len(self.frames)) + ".png"
            self.frames.append(fr2)
            os.system("cp -f %s %s" % (fr, fr2))
536011
def interrupt(self):
		
		self.image = io.BytesIO()
		self.renderer.screen.save(self.image, "png")
932458
def pause() -> None:
    
    if _logger is not None:
        _log(INFO, "Process", local.name, "pause")
    Process.current().rsim()._gr.switch()
1242044
def pause(self):
		
		if self.status == RUNNING:
			self.status = PAUSED
			self.previous_intervals.append(time.time() - self.interval_start)
			self.current_interval_duration = 0.0
		elif self.status == PAUSED:
			self.interval_start = time.time()
			self.status = RUNNING
952717
def pause(self):
        """"""
        self._mq.send("p", True, type=1)
        self._paused = True
252442
def close_stream(self):
        """"""
        if not self.is_connected:
            return

        self.stream.close()
        self.state = DISCONNECTED
        self.on_close.send(self)
313428
def stop(self, stopSparkContext=True, stopGraceFully=False):
        
        while self._on_stop_cb:
            cb = self._on_stop_cb.pop()
            log.debug('calling on_stop_cb {}'.format(cb))
            cb()

        IOLoop.current().stop()

        StreamingContext._activeContext = None