content: package kotlinx.coroutines.channels;
  
  import java.util.concurrent.CancellationException;
  import kotlin.Metadata;
  import kotlin.coroutines.CoroutineContext;
  import kotlin.jvm.internal.Intrinsics;
  import kotlinx.coroutines.CoroutineExceptionHandlerKt;
  import kotlinx.coroutines.DebugStringsKt;
  import kotlinx.coroutines.ExceptionsKt;
  import kotlinx.coroutines.Job;
  import mt.Log1F380D;
  
  @Metadata(d1 = {"\u00002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0010\u0003\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u0002\b\u0012\u0018\u0000*\u0004\b\u0000\u0010\u00012\b\u0012\u0004\u0012\u0002H\u00010\u00022\b\u0012\u0004\u0012\u0002H\u00010\u0003B#\u0012\u0006\u0010\u0004\u001a\u00020\u0005\u0012\f\u0010\u0006\u001a\b\u0012\u0004\u0012\u00028\u00000\u0007\u0012\u0006\u0010\b\u001a\u00020\t¢\u0006\u0002\u0010\nJ\u0010\u0010\u000b\u001a\u00020\t2\u0006\u0010\f\u001a\u00020\rH\u0014J\u0012\u0010\u000e\u001a\u00020\u000f2\b\u0010\u0010\u001a\u0004\u0018\u00010\rH\u0014¨\u0006\u0011"}, d2 = {"Lkotlinx/coroutines/channels/ActorCoroutine;", "E", "Lkotlinx/coroutines/channels/ChannelCoroutine;", "Lkotlinx/coroutines/channels/ActorScope;", "parentContext", "Lkotlin/coroutines/CoroutineContext;", "channel", "Lkotlinx/coroutines/channels/Channel;", "active", "", "(Lkotlin/coroutines/CoroutineContext;Lkotlinx/coroutines/channels/Channel;Z)V", "handleJobException", "exception", "", "onCancelling", "", "cause", "kotlinx-coroutines-core"}, k = 1, mv = {1, 6, 0}, xi = 48)
  /* compiled from: 0186 */
  class ActorCoroutine<E> extends ChannelCoroutine<E> implements ActorScope<E> {
      public ActorCoroutine(CoroutineContext parentContext, Channel<E> channel, boolean active) {
          super(parentContext, channel, false, active);
          initParentJob((Job) parentContext.get(Job.Key));
      }
  
      /* access modifiers changed from: protected */
      public boolean handleJobException(Throwable exception) {
          CoroutineExceptionHandlerKt.handleCoroutineException(getContext(), exception);
          return true;
      }
  
      /* access modifiers changed from: protected */
      public void onCancelling(Throwable cause) {
          Channel channel = get_channel();
          CancellationException cancellationException = null;
          if (cause != null) {
              Throwable th = cause;
              if (th instanceof CancellationException) {
                  cancellationException = (CancellationException) th;
              }
              if (cancellationException == null) {
                  String classSimpleName = DebugStringsKt.getClassSimpleName(this);
                  Log1F380D.a((Object) classSimpleName);
                  String stringPlus = Intrinsics.stringPlus(classSimpleName, " was cancelled");
                  Log1F380D.a((Object) stringPlus);
                  cancellationException = ExceptionsKt.CancellationException(stringPlus, th);
              }
          }
          channel.cancel(cancellationException);
      }
  }
  